spring-kafka

Вопрос или проблема Я пытаюсь отправить сообщения в две разные темы Kafka, используя KafkaSender из Reactor Kafka. Под двумя разными темами Kafka я имею в виду: Есть тема под названием “first_topic” в кластере kafka-first-broker.

Вопрос или проблема У меня есть 2 приложения SpringBoot, развернутых в AWS, APP1 управляет автомобилями, и для каждого нового добавленного автомобиля он создаст 2 темы kafka, которые будут использоваться только для этого автомобиля (тема A для событий APP1 ->

Вопрос или проблема Я сталкиваюсь с исключением ProducerFencedException при попытке синхронизировать события между Kafka и базой данных PostgreSQL, используя Spring Kafka. События отправляются в Kafka, и база данных обновляется успешно, и я могу видеть

Вопрос или проблема У меня есть требование, где мне нужно создать несколько записей с разными ключами, используя привязки Spring Cloud Kafka. @Getter @Setter public class Transaction { private String paymentRef; private String List<

Вопрос или проблема Я написал код Kafka Consumer с использованием Apache Kafka и интегрировал его в свое приложение Camel, но при попытке развернуть образ в кластере Kubernetes возникает следующая ошибка для маршрута: Ниже приведен мой код: `@Override

Вопрос или проблема Я пытаюсь настроить обработку ошибок для слушателя батчей таким образом, чтобы, если одна запись не удается обработать, весь батч отправлялся в топик мёртвых писем (с некоторым дополнительным логированием).