https://kafka.apache.org

启动zookeeper

zookeeper-server-start.bat ../../config/zookeeper.properties

默认监听2181端口

停止zookeeper

zookeeper-server-stop.bat

启动kafka

kafka-server-start.bat ../../config/server.properties

默认监听9092端口

停止kafka

zookeeper-server-stop.bat

创建主题topic

kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1  --topic test

查看主题列表

kafka-topics.bat --list --bootstrap-server localhost:9092

查看主题描述

kafka-topics.bat --describe --bootstrap-server localhost:9092

删除主题

kafka-topics.bat --delete --bootstrap-server localhost:9092 --topic test

创建生产者，发送消息；

修改CMD默认编码

chcp 65001

kafka-console-producer.bat --broker-list localhost:9092 --topic test

>你好

>hello

创建消费者，拉取消息；

修改CMD默认编码

chcp 65001

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

这里，可以看到生产者发送消息，消费者接收消息；

关闭kafka

zookeeper-server-stop.bat

关闭zookeeper

zookeeper-server-stop.bat

#查看各个分区的最小offset

kafka-run-class kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -2

返回：test:0:18

#查看各个分区的最大offset

kafka-run-class kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -1

返回：test:0:0

#测试多主题

kafka-console-consumer.bat –bootstrap-server localhost：9092 –whitelist "test1|test2|test3" --from-beginning

自己保存offset，这样不会丢失；自动提交使用默认，自动提交，看似简单方便，一旦遇到问题后想指定offset去弥补就麻烦了。