本文基于kafka.2.7.1 scala 2.13 Centos环境
kafka会按照默认配置，在9092端口上运行，并连接zookeeper的默认端口2181
创建主题（Topic）
1
|
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic demo
|
查看主题（Topic）
1
|
kafka-topics.sh --list --zookeeper localhost:2181
|
创建生产者（Producer）
1
|
kafka-console-producer.sh --broker-list localhost:9092 --topic demo
|
创建消费者（Consumer）
1
2
3
4
|
kafka-console-consumer.sh --zookeeper localhost:2181 --topic demo --from-beginning
kafka版本1.2.2后，启动消费者为：
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic demo
|
删除主题（Topic）
1
|
kafka-topics.sh --delete --topic demo --zookeeper localhost:2181
|
