kafka2.1.1在windows下的单机使用

    xiaoxiao2022-07-05  229

    启动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)。

    最新回复(0)