spring-cloud-stream

0зной

2ответ

Каким образом потребительское автоматическое потребление кафки весенне-облачного потока нечеткое?

Когда я вручную признаю смещения в потребительском приложении, но я хочу, чтобы потребитель мог получить сообщение unacknowledge автоматически, но я не могу добиться успеха. это мой конфиг YML: cloud:

0зной

1ответ

Spring Cloud Stream RabbitMQ

Как я могу вернуть сообщение1, полученное с помощью addAnnonceInput, мне нужно вернуть это сообщение клиенту. @RequestMapping(method = RequestMethod.POST, value = "/annonces") public void addAnnonce(

2зной

1ответ

Весна Облако поток Кафка потребительские модели

Для темы с несколькими разделами - 1) использовать ли один экземпляр SpringBoot несколько потоков для обработки (метод с аннотацией StreamListener) каждое сообщение из каждого раздела? 2) Можно ли нас

0зной

1ответ

Конфигурирование Spring Cloud Stream в Camden.SR5 с весенним ботинком 1.5.1

Прежде всего, благодаря команде Spring для всей их работы, толкая эту работу вперед! Теперь, когда Camden.SR5 является официальным, у меня есть некоторые вопросы о том, как правильно настроить весенне

0зной

1ответ

Spring Cloud Stream - программная публикация

Мне интересно, можно ли использовать источник потока вместо опроса. Мой источник будет, как это (не будет работать): @SpringBootApplication @RestController @EnableBinding(Source.class) public class

6зной

2ответ

Как реализовать микросервисную архитектуру Event Driven с Spring Cloud Stream Kafka и Database for service

Я пытаюсь реализовать архитектуру, управляемую событиями, для обработки распределенных транзакций. Каждая служба имеет свою собственную базу данных и использует Kafka для отправки сообщений для информ

1зной

1ответ

Производитель Non Spring Cloud Stream (SCS), отправляющий сообщение JSON потребителю SCS

У меня есть производитель не SCS (приложение Spring-Kafka), пытающееся отправить сериализованный объект json в тему, подписанную потребителем SCS. Сообщение положить на эту тему есть - { "сообщение":