Я хочу понять, как мы можем справиться с ситуацией, когда сам брокер не работает, в моем случае это...

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

Я пытаюсь создать наблюдаемое из ответа Streamlistener, но не могу этого сделать.Я совершенно...

Я отправляю список массивов от производителя, и я ожидаю прочитать тот же самый массив данных у...

с @PostConstruct и автоматическим подключением MessageChannel, я нашел решение SmartLifecycle.start...

Я работал над приложением на основе микросервиса для электронной коммерции.Структура HTTP-запроса:...

Я хотел бы использовать Kafka для выполнения ограниченной пакетной обработки , когда программа...

Топология, которую я ищу, До сих пор я не видел способа определения темы для каждого сообщения в...

Для чтения данных в KStream я использую связку kafka из весеннего облака. При чтении данных из...

Я пытался заставить входящий SubscribeableChannel и исходящий MessageChannel работать в моем...

Я использую Spring Cloud Stream для обмена сообщениями. В потребительской части я использовал...

У меня есть необработанные потоки из 3 таблиц mysql, 1 основной и двух дочерних таблиц. Я попытался...

Попытка создать zipkin-сервер с зависимостями, добавленными в gradle, как показано ниже, compile...