Мой вопрос очень близок к Выводить ввод Kafka Stream на консоль? с небольшой разницей: я использую StreamsBuilder вместо Kstreambuilder. (К сожалению, git с таким разрешением недоступен из-за ошибки 404). Мой слушатель:...

Мне нужно получать сообщения из тем, которые динамически создаются производителем. Я использовал подход шаблона темы в потребителе @KafkaListener (topicPattern = "topicname _. *" Для этого, а также установил metadata.max.age.ms = 3000. Но, очевидно,...

В отличие от @KafkaListener , похоже, что @StreamListener не поддерживает параметр autoStartup . Есть ли способ добиться такого же поведения для @StreamListener ? Вот мой вариант использования: У меня есть универсальное приложение Spring,...