Я разработал приложение для весенней загрузки, используя boot-версию 2.1.3.RELEASE. Добавлены...

Я использую spring-kafka-2.2.9.RELEASE и kafka_2.12-2.3.0. Я пытался получить original payload в...

Kafka Concurrent Consumer делает автоматическое принятие кафки в значение false. Затем, основываясь...

Я пытаюсь написать стойкого потребителя Кафки. Если при обработке сообщения в методе слушателя...

У меня есть потребительский метод kafka, аннотированный @kafkalistener. Я установил шаблон...

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

есть ли способ отловить исключение из данных Spring и классифицировать Повторяемые исключения:...

У меня есть метод прослушивания Kafka, аннотированный @kafkaListener. Он принимает аргумент типа...

Я хотел бы выяснить, как лучше всего перенаправлять сообщения от Kafka на клиенты веб-сокетов,...

Я немного озадачен ConcurrentKafkaListenerContainerFactory и setErrorHandler(org.springframework

У нас есть микросервисная архитектура в нашем проекте. Существует микросервис, в котором...

Я пытаюсь понять, как управлять org.apache.kafka.common.errors.SerializationException в Spring...

Я пытаюсь прочитать запрошенный номер сообщения kafka. Для нетранзакционных сообщений мы будем...

Я реализовал потребителя Kafka, теперь у меня есть сценарий. Чтение данных из потока Kafka 2.2.5....

Я проектирую работу в режиме реального времени, требующую кафки, и рассматриваю между загрузкой...

У меня следующая проблема. Мне нужно установить время хранения в Кафке для определенных выбранных...

У меня есть потребительское приложение kafka, где в методе слушателя аннотируется @Kafkalistener. Я...

В случае сбоя потребителя после повторных попыток, я вижу, что вся полезная нагрузка регистрируется

У меня есть IntegrationFlow для приема сообщений от Kafka и маршрутизации их к конечным точкам...

В настоящее время я отправляю данные с использованием spring-kafka следующим образом: val json =...

Встроенный брокер Kafka для Spring не работает при обновлении Spring-Kafka 2.2.x, что требуется для...

В настоящее время я пишу kafka cosumer. Работа потребителя заключается прежде всего в создании...

Я запускаю тест Junit с использованием EmbeddedKafka, я могу производить и использовать для...

Я использовал версию Spring Kafka 1.3.8 с клиентом apache kafka 0.11.0.2. Поскольку мой брокер...

У меня есть приложение весенней загрузки, в котором Spring для Apache Kafka используется для...