启动zookeeper和Kafka之后，进入kafka目录（安装/启动kafka参考前面一章：https://www.cnblogs.com/cici20166/p/9425613.html）
1.创建Topic
1）运行命令： ./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1
2181 是zookeeper 端口
图示为创建成功：
2.查看Topic
1）运行命令查看所有的topic： ./bin/kafka-topics.sh --list --zookeeper localhost:2181
结果如下图，表示共有test和test1两个topic：
3.用Kafka的console-producer在topic test1 生产消息
新建终端窗口，到/Applications/kafka目录，运行命令：./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1
然后输入想要产生的消息内容（如 hello world），回车：
4.用Kafka的console-consumer 消费topic test1的消息
新建终端窗口，到/Applications/kafka目录，
运行命令：./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test1 --from-beginning
（9092是kafka单机启动的端口；--bootstrap-server 新旧kafka版本不一样，这个是新版本的命令）
ps. 1)若producer 和 consumer 两个窗口同时打开，在producer输入信息，consumer会立即消费信息并打印在终端
2）新开一个终端，去消费同一个topic，刚刚已经消费过的消息还会被新终端继续消费。也就是说，消息被消费过后不会立即被删除。
原文地址：https://www.cnblogs.com/cici20166/p/9426417.html