1.console窗口:
producer:
consumer:
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_test_topic --from-beginning
2.查看消费情况:
列出所有consumer group:
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
查看组消费情况:
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my_group_02
./kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group my_group_02
查看组中存活的consumer
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my_group_02 --members
查看组中存活的consumer消费的partition
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my_group_02 --members --verbose
3.查看log文件中消息内容:
server.properties 配置文件中log.dirs配置项即为log文件所在路径
到bin目录下执行:
./kafka-run-class.sh kafka.tools.DumpLogSegments --files 目标log文件 --print-data-log