У меня есть тема Kafka gbtopic с 12 разделами и группой потребителей gbconsumers с тремя...

У меня есть Java-код, он часто потребляет XML-данные из раздела Kafka. Я хочу написать свой вывод...

Мне нужен SpringReatch ItemReader для приема сообщений Kafka, результаты которых будут обработаны и...

У меня есть тема kafka с 2 разделами, я хочу создать потребителя для чтения темы с заданным...

B1, B2, B3 - брокеры Уменьшите B2, B3 - теперь B1 становится лидером по темам Уменьшить B1...

Как мне получить размер одной записи в Kafka? Существует некоторая информация о том, зачем мне это...

Я написал простой клиент для чтения из темы Кафки, которая работала хорошо, пока я не понял, что...

В проекте моей новой работы я обнаружил, что вместо непосредственного выполнения API-вызовов post /...

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

В группе 10 потребителей, слушающих какую-то тему.Очень часто случается так, что очень часто...

Я пытаюсь использовать сообщения из нескольких тем, используя метод assign(). С моей реализацией,...

У меня есть функция в Java, в которой я пытаюсь получить сообщения, которые не прочитаны.Например,...

Я публикую сообщения внешней команде, которая принимает сообщения для Кафки и возвращает нам ответ

Название темы: testTopic Всего сообщений в теме: 1 Раздел: 8 Название группы потребителей:...

Потребитель Alpakka kafka обрабатывает записи до тех пор, пока не обнаружит запись, которую он не...

Мне интересно, есть ли что-то, чего мне не хватает в моей настройке, чтобы облегчить длительные...

Внезапно у меня возникла проблема с запуском группы потребителей apache kafka. Кто-нибудь,...

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

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

У меня есть тема с сообщениями, и есть потребитель с именем группы как "KafkaConsumerExample".когда...

Я пытаюсь добавить пользовательский перехватчик, используя org.apache.kafka.clients.consumer

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

Я установил enable.auto.commit = Ложь Теперь я читаю некоторые данные из Кафки и почему-то не могу...

У меня есть следующие варианты использования: Предположим, у вас есть две микро-службы: одна...

У меня есть приложение kafka streams (Kafka v1.1.0) с несколькими (24) темами.Четыре из этих тем...