Windows下Kafka操作命令_windows命令行消费kafka

在使用Kafka之前，需要安装运行ZooKeeper，这里默认已经启动zookeeper（安装启动zookeeper的操作以后补上）

单机Kafka的使用

1. 修改kafka配置

打开kafka目录下的config目录，打开server.properties文件，找到 “log.dirs” 属性，把对应的log保存地址修改成windows的地址，具体目录自行创建

2. 启动kafka服务

进入kafka的安装目录（bin文件夹的根目录），打开一个dos窗口，执行命令

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

命令行的意思是进入bin/windows目录下调用名为kafka-server-start.bat 的批处理文件，启动配置文件位于config目录下的server.properties

3.创建topics

进入kafka目录下的bin/windows命令，该目录下存放在windows平台上执行的所有的bat文件，打开一个新的Dos窗口，执行命令

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic Hello-kafka

--开头的是.bat脚本的参数，在本机创建一个包含一个分区和一个副本因子的名为Hello-kafka的topic

3.1 显示现存的topic

kafka-topics.bat --list --zookeeper localhost:2181

4.操作生产者（Producer）

在bin/windows目录下，打开一个新的Dos窗口，执行命令

kafka-console-producer.bat --broker-list localhost:9092 --topic Hello-kafka

打开消息生产者，执行命令以后，在dos窗口输入消息，之后由消费者获取

5.操作消费者

在bin/windows目录下，打开一个新的Dos窗口，执行命令

kafka-console-consumer.bat --bootstrap-server localhost:9092 -topic Hello-kafka --from-beginning

在新版kafka中，之前的--zookeeper命令被 --bootstrap-server代替，端口号为9092