启动Kafka

启动zookeeper

使用命令查看zookeeper是否启动成功：

启动kafka Brokerr

使用命令查看kafka Broker是否启动更成功

在kafka中创建topic 'test'

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

列出所有的topic

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

 

产生数据