Результаты поиска по запросу "kafka-consumer-api"
разница между groupid и consumerrid в Kafka
Я новичок в Кафке. Я заметил, что в конфигурации Consumer есть два идентификатора. один - group.id (обязательный), а второй - consumer.id (не обязательный). ...
Как происходит перебалансирование потребителей в Кафке?
Когда новый потребитель / посредник добавляется или выходит из строя, Kafka запускает операцию восстановления баланса. Является ли Кафка ребалансировкой опер...
Координатор также является тем, кто одобряет / не одобряет коммиты от каждого отдельного потребителя, это правда?
у ссылки на координаторов группы потребителей Kafka и лидеров группы потребителей ...В чем разница?Какая польза от разделения группового управления на два ра...
Мне пришлось добавить эту строку непосредственно перед вызовом опроса, кажется, что теперь все работает: kafkaConsumer.seekToBeginning (kafkaConsumer.assignment ())
денный ниже клиент Scala kafka не возвращает никаких событий изpoll вызов. Тем не менее, тема правильная, и я вижу события, отправляемые в тему с помощью консоли: /opt/kafka_2.11-0.10.1.0/bin/kafka-console-consumer.sh ...
kafka.consumer.SimpleConsumer: переподключение из-за ошибки сокета: java.nio.channels.ClosedChannelException
Я использую простой потребитель для кафки, такой как этот:
Алгоритм перебалансировки потребителей Kafka
Может кто-нибудь сказать мне, что алгоритм перебалансировки для потребителей Kafka? Я хотел бы понять, как подсчет разделов и потребительские потоки влияют н...