Мы используем spring-integration-kafka версии 3.1.2.RELEASE и int-kafka: message-driven-channel-adapter для получения сообщений из удаленной темы kafka. Производитель отправляет зашифрованное сообщение, и мы расшифровываем фактическое сообщение с...

Я пытаюсь создать потребителя Kafka для темы без использования аннотации @KafkaListener. Я хочу сделать это, потому что пытаюсь динамически создавать слушателей на основе application.properties без использования весенней загрузки. Я подумал, что...