启动服务
- 安装配置好zookeeper,添加好环境变量,打开cmd,输入命令启动服务。
zkServer
- 在%KAFKA_HOME%目录,按shift+鼠标右键,选择“在此处打开命令窗口”,在控制台输入命令启动服务。
.\bin\windows\kafka-server-start.bat .\config\server.properties
kafka命令
- 创建主题
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic 主题名
- 查看主题
.\bin\windows\kafka-topics.bat --zookeeper localhost:2181 --list
- 启动生产者producer:
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic 主题名
- 从文件中向主题批量发送数据:
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic 主题名 < 文件名
- 启动消费者consumer
.\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic 主题名