windows环境搭建kafka（二）

运行并测试Kafka

一.执行并打开kafka

• 打开cmd， 进入kafka文件目录: D:\kafka\kafka_2.12-2.1.0
• 输入并执行以打开kafka:

.\bin\windows\kafka-server-start.bat .\config\server.properties

二.创建topics

• 打开cmd 并进入D:\kafka\kafka_2.12-2.1.0\bin\windows
• 创建一个topic：

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic demo  

QQ拼音截图未命名.png

• 打开一个Producer:
  cd D:\kafka\kafka_2.12-2.1.0\bin\windows

kafka-console-producer.bat --broker-list localhost:9092 --topic demo

• 打开一个Consumer:

cd D:\kafka\kafka_2.12-2.1.0\bin\windows

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic demo --from-beginning

QQ拼音截图未命名.png

创建成功！