Я использую spring-kafka для springboot 2.0.4.RELEASE. И использовать KafkaListener для получения...

Я пытаюсь вывести конфигурацию приложения spring-kafka, которое я сейчас написал в коде Java.Должен...

Я пытался проверить нашу Кафку на наличие некоторых негативных сценариев, и один из них - очень...

У меня есть слушатель kafka, настроенный в нашем приложении Spring Boot следующим образом:...

Я пытаюсь разработать потребительский класс в Spring Boot для Kafka (kerberos).Я внес необходимые...

Я пытаюсь начать новый проект с spring.boot version: 2.1.5.RELEASE и Kafka version: 2.0.1 и...

Существует полезная метрика для мониторинга отставания потребителя Kafka в spring-kafka, называемая...

Я пытаюсь обновить наш KafkaBroker с 0.10.2 до 1.1.3 , включая формат журнала сообщений. В...

Я пытаюсь разработать Kafka Consumer в Spring Boot.Я могу настроить Kafka Cluster в Kafka Tool и...

Я немного озадачен рекомендациями по настройке тайм-аута события, публикуемого синхронно через...

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

Мы используем весенний конфигурационный клиент для динамического обновления свойств. Мы добавили...

Я следил за этим сообщением в блоге, чтобы реализовать встроенный sasl_ssl https://sharebigdata

У меня есть код, в котором я использую SPEL в @KafkaListener. Я пытаюсь предоставить ссылку на...

У меня есть приложение весенней загрузки с несколькими экземплярами (несколько слушателей и...

Я пишу тестовый класс, который имеет несколько методов, которые требуют Kafka.Каждому из них...

Я делаю простой пример проекта kafka со Springboot, и у меня возникает ошибка, когда производитель...

Если я запускаю одного и того же Потребителя Spring-Kafka для одной и той же темы kafka на другом...

Я создал потребителя kafka в своем весеннем загрузочном приложении, которое слушает тему - my_topic...

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

Я немного запутался в связи между max.in.flight.requests.per.connection для Kafka Producers и...

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

Я пытаюсь создать темы Kafka, используя Java. Но я получаю Exception in thread "main"...

Когда мы инициализируем EmbeddedKafkaBroker с: EmbeddedKafkaBroker embeddedKafkaBroker = new...

Я использую ReplyingKafkaTemplate в моем контроллере Rest для возврата синхронного ответа.Я также...