Я использую производителя kafka и потребителя Spring kafka. Я использую сериализатор и...

У меня есть ситуация, когда я хочу использовать несколько потребителей на JVM.Я использую...

Я использую Spring kafka listener для чтения сообщений из темы kafka. @KafkaListener( id =...

Я настроил 3 kafka в кластере и пытаюсь использовать с spring-kafka. Но после того, как я убил...

Я пишу крайний случай, чтобы узнать, работает ли сервер kafka или нет, поэтому я написал...

У меня есть следующие настройки: несколько сервисов Spring Cloud Edgware с наиболее заметными...

Я использую Spring Boot 2.0.2 и Spring Kafka.Также я использую Kafka Docker image 1.1.0 из...

Я пытаюсь написать загрузочные приложения Spring для потребителя Reactive Kafka, используя...

У меня есть проект Spring-Kafka под управлением Spring Boot 2.0.2.В модульном тесте я пытаюсь...

Я создаю данные обработки KTable из KStream.Но когда я запускаю сообщения-захоронения с ключом и...

Среда: spring-boot.version - 1.5.9.RELEASE spring-kafka.version - 1.2.0.RELEASE Клиентская версия...

Я настроил kafka следующим образом: @Bean public ProducerFactory<String, String>...

Я создаю приложение kafka streams с помощью spring-kafka для группировки записей по ключу и...

Я разрабатываю некоторые тесты приложения, которое использует Kafka-streams, которое также...

Я пытаюсь создать простое потоковое приложение на основе Kafka Streams, используя этот пример....

У меня есть проект Spring Boot, который запускает несколько потребителей Kafka (@KafkaListener) по...

Как настроить log.cleanup.policy: сжатие с использованием конфигурации пружины

При аутентификации с неверными учетными данными во время аутентификации я получаю следующее...

Может кто-то, пожалуйста, дайте мне хороший пример и взаимосвязь между параметрами kafka...

У меня есть следующая реализация @Bean public KStream<Integer, String> kStream(StreamsBuilder...

У меня должно быть приложение микросервиса отдыха производителя-потребителя Apache kafka, в котором...

Как мы можем остановить потребителя Spring Kafka, если не осталось сообщений от производителя?Я...

У меня есть огромная масса записей данных для Kafka, использующих пакетную обработку и сжатие. Я...

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

, поэтому у меня есть контроллер конечной точки SpringBoot, который запускается так:...