Мне нужно, чтобы мой потребитель потреблял определенное количество TopicPartitionOffset(here from...

Я прочитал ветку boostrap-server против zookeeper на потребительской консоли , но мои сомнения не...

Пример кода построителя маршрутизации, как показано ниже: // For out of seq event state (reque)...

Я новичок в Kafka Java API и работаю над тем, чтобы использовать записи из определенной темы Kafka....

Я использую библиотеку Python Confluent kafka для приема сообщений, я хочу получить несколько...

Я хотел бы преобразовать строковый массив / список в util.Collection [String] объект в Scala.Я...

В моем приложении NodeJS я получаю сообщения от kafka, сообщения поступают в виде буфера, поэтому я...

Я довольно новичок в Kafka и использую API-интерфейс Confluent Kafka Python.Я планирую создавать...

У меня есть тема в кафке как internal.Я создал тему, используя приведенную ниже команду...

У меня есть тема, которая имеет довольно большой срок хранения и множество сохраненных данных.Я...

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

Я использую кластер Kafka с 4 узлами, 1 производителем и 1 потребителем.Он работал нормально, пока...

Я использовал Kafka 0.9 и недавно перешел на Kafka 1.0, но клиент, который я использую, по-прежнему...

Я хочу знать скорость, с которой тема используется.В метрике Кафки-менеджера есть Messages in /sec,...

Я пытаюсь соединить соединитель Kafka с базой данных, используя соединитель jafb kafka. Я могу...

Приведенный ниже потребитель Scala kafka не возвращает никаких событий из вызова poll. Тем не менее...

Если у меня есть одна тема, которая имеет 5 разделов, а затем у меня есть служба, потребляющая эти...

Я использую segmentio / kafka-go для подключения к Kafka. // to produce messages topic :=...

В настоящее время у моего потребителя kafka у меня отключена автоматическая фиксация , поэтому в...

Наша система kafka вышла из строя из-за отсутствия свободного места на диске.Потребителями являются...

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

Я установил kafka_2.11-1.1.0 и установил для объявленного слушателя значение advertised

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

Я читаю документацию Кафки и пытаюсь понять, как она работает.Это касается потребителей.Вкратце,...

Цель: прочитать все сообщения из темы, а затем прекратить процесс. Я могу непрерывно читать...