启动 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 关闭命令窗口也可杀死 生产/消费进程
