kafka2.1.1在windows下的单机使用

启动zookeeper

  1. 首先来到kafka的安装目录下kafka2.1.1在windows下的单机使用
  2. shift+右键,打开Powershell窗口
  3. 输入命令:bin\windows\zookeeper-server-start.bat config\zookeeper.properties
    kafka2.1.1在windows下的单机使用
  4. 有sessionid证明启动成功了

启动kafka

  1. 不要关闭以上窗口,同样在kafka安装目录下打开新的Powershell窗口
  2. 输入命令: bin\windows\kafka-server-start.bat config\server.properties
  3. 同上,输入命令后不要关闭窗口
    kafka2.1.1在windows下的单机使用

创建topic

  1. 同上,另开Powershell,输入命令:bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic demo
  2. 上述命令最后的demo是topic名
  3. 查看topic是否创建成功:bin\windows\kafka-topics.bat --list --zookeeper localhost:2181kafka2.1.1在windows下的单机使用

创建生产者

  1. 同上,另开窗口,输入命令: bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic demo
  2. 发送消息:hellokafka2.1.1在windows下的单机使用

创建消费者

  1. 同上,另开窗口,输入命令:bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic demo --from-beginningkafka2.1.1在windows下的单机使用

总结

由于对2181端口与9092端口的了解不够透彻,导致走了不少弯路,以上可得知topic由zookeeper创建于2181端口,消费者与生产者均由kafka创建于9092端口,本次实验共开了4个Powershell窗口(zookeeper,kafka,producer,consumer)。