Я пытаюсь получить сообщение по ключу от Кафки. Я нашел только одно решение - использовать...
Интеграция 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 (на основе идентификатора отдела и т. Д.), И...