Kafka 常用命令

启动 zookeeper

bin/zkServer.sh start

启动 kafka

bin/kafka-server-start.sh -daemon config/server.properties

关闭kafka

由于是优雅启停，等待数秒

bin/kafka-server-stop.sh config/server.properties

创建 Topic 

分区数：1，分区副本数：1

./kafka-topics.sh --zookeeper 127.0.0.1:2181 --partitions 1 --replication-factor 1 --create --topic topicName

删除 Topic

./kafka-topics.sh --zookeeper 127.0.0.1:2181  --delete --topic topicName

启动生产者

./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic topicName

启动消费者

./kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092  --topic topicName

--from-beginning #加了--from-beginning 重头消费所有的消息

查看 Topics 列表

./kafka-topics.sh --zookeeper 127.0.0.1:2181 --list

查看 kafka 数据量 - 最小offset

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 127.0.0.1:9092 --topic TOPIC_NAME --time -2

查看 kafka 数据量 - 最大offset

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 127.0.0.1:9092 --topic TOPIC_NAME --time -1

获取 Group 当前offset

./kafka-consumer-groups.sh --describe --group groupName --bootstrap-server 127.0.0.1:9092

手动设置offset 

设为10000

./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group groupName --topic  topicName --execute --reset-offsets --to-offset 10000

设为最早 offset

./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group GROUP_NAME  --reset-offsets --execute --to-earliest --topic TOPIC_NAME

设为最迟 offset

./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group GROUP_NAME  --reset-offsets --execute --to-latest --topic TOPIC_NAME

查看 Group 列表

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

查看topic详情(分区数)

./kafka-topics.sh --zookeeper localhost:2181 --describe --topic TopicName

修改topic分区数

./kafka-topics.sh --alter  --zookeeper localhost:2181  --topic TopicName  --partitions 分区数量

查看topic下group的消费情况

./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group group_name --describe