启动 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