kafka-consumer-api

0зной

1ответ

Kafka - Fail Connecting Remote Broker - NoBrokersAvailable

Я создал кластер (облако Google) с тремя узлами. Zookeeper работает на всех узлах, и я начал Kafka на одном из подчиненных узлов. Я могу общаться (публиковать/потреблять) с любого компьютера в кластер

0зной

1ответ

Kafka член id магазин в ZK?

Кто-нибудь знает, что идентификатор участника был сохранен в zookeeper или Kafka? Как его удалить или отправить Leave Group Request, чтобы удалить его.

1зной

1ответ

Прочтите ключи только от Kafka

Можно ли читать только ключи от Kafka? У нас есть приложение, в котором значения, хранящиеся в журнале Kafka, довольно велики. Чтобы отлаживать и быстро проверять, есть ли какое-либо сообщение в журна

0зной

1ответ

Если мой продюсер продюсирует, то почему потребитель не мог потреблять? он застрял @ poll()

Публикация на удаленном сервере kafka и попытка использования сообщений с этого удаленного сервера. (Kafka v 0.90.1) Издательская деятельность отлично работает, но не потребляет. Издательство package

0зной

1ответ

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

У меня есть два клиентских сервера с одинаковым идентификатором группы, которые подписали одну и ту же тему. Сервер kafka работает только с одним разделом. Насколько я знаю, сообщение должно потреблят

2зной

1ответ

kafka перераспределение раздела (задание) занимает слишком много времени

Мы используем кластер kafka с 3 серверами, все они также имеют zookeeper. у нас есть 7 тем, каждый из которых состоит из 6 разделов. У нас есть 3 потребителя java для каждой темы. Когда я запускаю пот