0
Кто-нибудь знает, что идентификатор участника был сохранен в zookeeper или Kafka? Как его удалить или отправить Leave Group Request, чтобы удалить его.Kafka член id магазин в ZK?
A
ответ
0
Идея groupId для потребителей.
https://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html
./bin/kafka-consumer-groups.sh --zookeeper zookeeper:2181/path --group your_group_id --delete
В Кафки 0,8 смещения хранились в Zookeeper. Вы можете найти их, если вы используете браузер zookeeper tree. В Кафке 0,9 смещения были перенесены в кафку. Отдельная тема с уплотнением. Смотреть еще http://www.slideshare.net/jjkoshy/offset-management-in-kafka