Я пытаюсь получить сообщение по ключу от Кафки. Я нашел только одно решение - использовать...

Интеграция Spring Kafka Listener (DSL), который принимает сообщения из раздела Kafka и...

Я использую spring-kafka 1.1.3.RELEASE и kafka-clients 0.10.0.0, и я хочу установить...

Ссылка на 4.2.6 этого документа https://docs.spring

В моем приложении я использую spring-kafka для получения сообщения от сервера kafka, но от...

Я пытаюсь использовать executeInTransaction для публикации сообщений в kafka в Spring kafka. Но я...

Я использую пружинную кафку со следующими конфигурациями: props.put(ConsumerConfig

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

Я хочу создать одновременную @KafkaListener, которая может обрабатывать несколько тем, каждая с...

В данный момент работаю с spring-boot 2.0.4 с spring-kafka 2.1.8.RELEASE. Я хотел немного упростить...

Я отправляю данные ниже в kafka и получаю через каналы интеграции пружины и преобразую в объект Log...

Я реализовал потребителя Kafka с KafkaHandler.Предполагается, что мой потребитель использует...

В приложении Spring Boot я пытаюсь настроить Kafka Streams.С простыми темами Kafka все работает...

Я работаю над Spring Kafka Mongo Integration для операций вставки / обновления и использую...

Я пытаюсь добиться единовременной доставки с использованием spring-cloud-stream-binder-kafka в...

Я использую Spring-Cloud-Stream-Kafka в моем приложении Spring-Boot (потребитель). Состояние...

Я пытаюсь контролировать коммит смещения по теме кафки в соответствии со статусом обработки...

У меня мало сомнений насчет весеннего облачного потока (используя Кафку) .... Есть ли у Spring...

Я использую реестр Avro и Schema с моей установкой Spring Kafka. Я хотел бы как-то обработать...

У меня есть один вопрос и больше попыток понять, чтобы я мог правильно его реализовать. Требование...

У меня есть два микросервиса проекта с пружинной загрузкой 1.5.9.RELEASE, первый микросервис...

Мы планируем использовать Kafka для обмена сообщениями, а наши приложения разрабатываются с...

Мой слушатель kafka должен обрабатывать сообщения в последовательном порядке, метод onMessage...

Я использую фреймворк spring-kafka для реализации слушателя kafka. В настоящее время я читаю из...

У меня есть несколько динамических потребителей Kafka (на основе идентификатора отдела и т. Д.), И...