Я пытаюсь создать рабочий пример с производителем сообщений avro, kafka и потребителем avro, используя весеннюю загрузку, реестр схемы весеннего облачного потока, связыватель kafka. При использовании сообщений возникает следующая ошибка: ОШИБКА...

Согласно этой теме: Интеграция Kafka Spring: заголовки не идет для потребителя kafka - это не поддержка заголовков для Kafka Но документация говорит: spring.cloud.stream.kafka.binder.headers Список настраиваемых заголовков, которые...

Я впервые использую Spring Kafka, и я не могу использовать метод Acknowledgement.acknowledge () для ручной фиксации в моем пользовательском коде. пожалуйста, дайте мне знать, если что-то отсутствует в моей конфигурации потребителя или коде слушателя....

Я использую springboot и пытаюсь написать KafkaProducer для отправки сообщений в очередь Kafka. Я создал эти методы в классе @Configuration. @Bean public KafkaTemplate<String, String> kafkaTemplate(){ return new...