kafka的windows下使用

安装

1.kafka 需要java环境；

 2.kafka 最新版本内置了 zookeeper，所以不需要安装zookeeper；

3.下载kafka最新版本，https://mirrors.bfsu.edu.cn/apache/kafka/，因为下载的是tgz文件，所以不需要安装，解压到相应的地方就可以了。

4.bin 目录下放的是启动kafka的linux文件，windows下是kafka的windows文件，conf目录下放的是kafka的各种配置文件。

windows下使用

1、启动zookeeper

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

      2、启动kafka

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

      3、创建主题topic，topic = test

bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

-- 查看创建的topic

bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092

      4、启动生产者 producer

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

启动生产者之后进入编辑页面，可以发送信息，

       5、启动消费者 customer

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