У меня есть простой поток интеграции Spring, который привязывается к процессору для ввода и вывода. Я настроил связующее Kafka для сопоставления темы ввода и вывода. Это работает отлично. Скажем, я хочу привязать 3 темы Kafka к входным данным,...

Я использую библиотеку Spring Cloud Stream в приложении Java. Я хочу использовать связыватель Kafka Streams для государственного магазина. Приложение будет публиковать сообщения в теме, и я хочу использовать потоки Kafka InteractiveQueryService...

У меня есть проект Spring Cloud Stream, использующий связыватель Kafka, и я пытаюсь понять и в конечном итоге настроить RetryTemplate, используемый Cloud Stream. Я не нахожу много документации о том, как это работает, но то, что я прочитал,...

Мы используем spring-cloud-stream и планируем обновить нашу версию Kafka. Наши приложения используют spring-cloud-stream:2.0.0 (spring-kafka 2.1.7) с сервером apache kafka 1.0.1 , а также используют spring-cloud-sleuth:2.0.0 для отслеживания....

Я пишу Kafka Producer and Consumer, используя Spring Cloud Stream Kafka binder. Мне нужен доступ к следующей информации как у производителя, так и у потребителя а) Тема б) Разделение б) Смещение Я проверил документацию и не могу найти, где это...

Я знаю, что Kafka Streams позволяет распределять данные по нескольким темам на основе указанных предикатов, а связыватель Kafka Streams поддерживает это, используя подходы @StreamListener и functional binding . ... // return type KStream<?,...

Я изо всех сил пытаюсь найти какую-либо документацию о том, где я могу использовать Spring Cloud Streams, которая берет тему Kafka и помещает ее в KTable. Посмотрев документацию, например, здесь...