Я хочу обработать исключение сервера DisconnectException и завершить работу приложения, когда...

Как мне остановить весеннюю кафку, не повторять не прочитанные сообщения из темы. Например, я...

У меня есть получатель, имеющий несколько обработчиков, и когда у потребителя есть прослушиватель...

Я продолжаю писать свой первый потребитель Kafka, используя Spring-Kafka.Посмотрел различные...

Я отправляю сообщение в Kafka с помощью ReplyingKafkaTemplate, и оно отправляет сообщение с...

У меня есть простое приложение Spring Boot, которое читает из Kafka и пишет в Kafka. Я написал...

Я использую Spring Kafka с аннотацией @EmbeddedKafka для запуска экземпляра Embedded kafka....

Я пишу для потребителя Kafka и в целях обучения на этот раз я подумал об использовании реализации...

Есть ли пакеты обработки ошибок свойства spring.kafka spring.kafka.listener.type=BATCH и spring

Я настроил своего потребителя на прием сообщений от темы в пакетном режиме. Как переслать его в...

Spring Cloud Stream и кафка. Эта ошибка появляется после добавления следующих зависимостей. (Если я...

Мои spring-boot application(consumer) обрабатывают сообщения от Apache Kafka.Периодически, массаж...

У меня есть два весенних менеджера транзакций. txManager1 - ChainedKafkaTransactionManager...

Я пытаюсь вручную установить кафку, но безуспешно. Потребитель не может быть настроен для...

Я создаю собственный десериализатор для потребителя кафки. но я получаю исключение удара -...

У меня есть xml <?xml version = ....... <A>1</A> <B>2</> </> Я...

Я использую spring-boot & spring-kafka (см. Pom.xml для конкретных версий) с Apache Kafka v2.0.1, и...

Мне нужно применить транзакции в системе, которая состоит из следующих компонентов: Производитель...

Ошибка при запуске проекта весенней загрузки kafka. пружинный ботинок: 2.1.2. ВЫПУСК Версия Spring...

Какая разница? Можно ли использовать термины KafkaConsumer и KafkaListener взаимозаменяемо?

У меня есть потребитель Kafka, который повторяет 5 раз, и я использую Spring Kafka с шаблоном...

В приложении № 1 я создаю KTable - KTable<Windowed<String>, GenericRecord> table =...

Я пытаюсь проверить темы Кафки при запуске Spring-boot приложения.Я хочу выбросить исключение и...

Я запускаю kafka на одном узле, я хочу увидеть поведение kafka Producer, когда я выключаю свой...

Я пишу загрузочное приложение Spring, которое будет использовать две разные темы и обрабатывать...