Kafka Notes

shell

查询消费者组

kafka-consumer-groups.sh --bootstrap-server bigdata7:9092 --list
kafka-consumer-groups.sh --bootstrap-server bigdata7:9092 --describe --group group_name

删除消费者组

kafka-consumer-groups.sh --bootstrap-server bigdata7:9092 --delete --group group_name

查看topic消息数量

kafka-run-class.sh kafka.tools.GetOffsetShell --bootstrap-server bigdata7:9092 --topic topic_name --time -1