1.查看所有主题

bin/kafka-topics.sh --bootstrap-server 192.168.10.100:9092  --list

2.创建主题

bin/kafka-topics.sh --create --bootstrap-server 192.168.10.100:9092 --replication-factor 1 --partitions 1 --topic test

3.增加主题分区

bin/kafka-topics.sh --bootstrap-server 192.168.10.100:9092,192.168.10.101:9092 --alter --topic test --partitions 2

4.查看主题详情

bin/kafka-topics.sh --bootstrap-server 192.168.10.100:9092 --describe --topic test

5.创建消费者组

bin/kafka-console-consumer.sh --bootstrap-server 192.168.10.100:9092 --topic test --consumer-property group.id=test-consumer-group

6.查看所有消费者组

bin/kafka-consumer-groups.sh --bootstrap-server 192.168.10.100:9092 --list

7.生产者生产消息

bin/kafka-console-producer.sh --bootstrap-server 192.168.10.100:9092 --topic test

8.消费者接收消息

bin/kafka-console-consumer.sh --bootstrap-server 192.168.10.100:9092 --topic test --group test-consumer-group --from-beginning

9.查看所有消费者组详情

bin/kafka-consumer-groups.sh --bootstrap-server 192.168.10.100:9092 --describe --all-groups

10.查询所有消费者成员信息

bin/kafka-consumer-groups.sh --bootstrap-server 192.168.10.100:9092 --describe --all-groups --members

11.查看消费者组消费情况

bin/kafka-consumer-groups.sh --bootstrap-server 192.168.10.100:9092 --describe --group test-consumer-group --members

12.重设位移位置

bin/kafka-consumer-groups.sh --bootstrap-server 192.168.10.100:9092 --group test-consumer-group --reset-offsets --topic test --to-offset 0 --execute

13.修改到最新offset

bin/kafka-consumer-groups.sh --bootstrap-server 192.168.10.100:9092 --group test-consumer-group --reset-offsets --topic test --to-latest --execute

14.删除消费者组

bin/kafka-consumer-groups.sh --bootstrap-server 192.168.10.100:9092 --delete --group test-consumer-group

15.删除主题

bin/kafka-topics.sh --delete --bootstrap-server 192.168.10.100:9092 --topic test