Я уже некоторое время пытаюсь заставить Spring Cloud Stream работать с Kafka Streams, в моем проекте для тестирования с Kafka DSL используется встроенная кафка, и я использовал этот репозиторий в качестве основы для моей тестовой реализации (он сам...

Просто пытаюсь найти простой пример с Spring Boot 2.1.12 и Spring для Apache Kafka 2.2.12, который работает с KafkaListener, чтобы повторить последнее неудачное сообщение. Если сообщение не удается, оно должно быть перенаправлено в другую тему, где...

Я хочу сделать KStream to KTable Join. используя KTable как просто справочную таблицу. ниже шаги показывают последовательность, в которой выполняется код Построить KTable ReKey KTable Создать KStream ReKey KStream...