启动 zookeeper 服务器

bin/zookeeper-server-start.sh  config/zookeeper.properties &

启动 kafka 服务器

bin/kafka-server-start.sh  config/server.properties  >/dev/null 2>&1 &

查看 zookeeper、kafka 进程

jps

创建一个叫做“test”的 topic，它只有一个分区，一个副本

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

通过 list 命令查看创建的 topic

bin/kafka-topics.sh --list --zookeeper localhost:2181

查看一个 topic 的分区及副本状态信息

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

启动 producer:运行 producer 并在控制台中输一些消息，这些消息将被发送到服务端

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

启动 consumer:接着再开启一个终端,运行 consumer 可以读取消息并输出到标准输出

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

查看生产/消费 topic 进程，若存在则手动杀死进行

jps -m

kill -9 进程号

或 在命令窗口使用 Ctrl + C 关闭命令窗口也可杀死 生产/消费进程