Kafka
下载
运行
- 先运行Zookeeper
PS D:\cloud\kafka\bin\windows> .\zookeeper-server-start.bat ....\config\zookeeper.properties
2. 再运行Kafka
PS D:\cloud\kafka\bin\windows> .\kafka-server-start.bat ....\config\server.properties
使用
- 创建一个主题
PS D:\cloud\kafka\bin\windows> .\kafka-topics.bat –create –zookeeper localhost:2181 –replication-factor 1 –partitions 1 –topic test
Created topic test.
可以通过list topic命令查看所有的主题
PS D:\cloud\kafka\bin\windows> .\kafka-topics.bat –list –zookeeper localhost:2181
test发送消息
PS D:\cloud\kafka\bin\windows> .\kafka-console-producer.bat –broker-list localhost:9092 –topic testhelloworld
are u ok消费消息
PS D:\cloud\kafka\bin\windows> .\kafka-console-consumer.bat –bootstrap-server localhost:9092 –topic test –from-beginning
helloworld
are u ok