kafka2.1.1在windows下的单机使用
启动zookeeper
- 首先来到kafka的安装目录下
- shift+右键,打开Powershell窗口
- 输入命令:bin\windows\zookeeper-server-start.bat config\zookeeper.properties
- 有sessionid证明启动成功了
启动kafka
- 不要关闭以上窗口,同样在kafka安装目录下打开新的Powershell窗口
- 输入命令: bin\windows\kafka-server-start.bat config\server.properties
- 同上,输入命令后不要关闭窗口
创建topic
- 同上,另开Powershell,输入命令:bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic demo
- 上述命令最后的demo是topic名
- 查看topic是否创建成功:bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
创建生产者
- 同上,另开窗口,输入命令: bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic demo
- 发送消息:hello
创建消费者
- 同上,另开窗口,输入命令:bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic demo --from-beginning
总结
由于对2181端口与9092端口的了解不够透彻,导致走了不少弯路,以上可得知topic由zookeeper创建于2181端口,消费者与生产者均由kafka创建于9092端口,本次实验共开了4个Powershell窗口(zookeeper,kafka,producer,consumer)。