windows 环境使用 kafka

近来学习 kafka,网上搜的教程好多不好用。在此开一贴记录一下学习过程。推荐官网,是最好的教程 http://kafka.apache.org/quickstart

官网上是linux 环境,我用的是windows 环境。已经安装过jdk

1 下载 kafka ,地址 http://kafka.apache.org/downloads

 2 解压,我把它解压到 D:serverkafka2.12,路径中最好不要有空格

3 修改配置文件 config 目录下的 zookeeper.properties 和 server.properties,

3.1 zookeeper.properties 配置文件修改数据存储目录

dataDir=D:/server/kafka2.12/zookeeper-logs

3.2 server.properties 修改数据存储目录

log.dirs=D:/server/kafka2.12/kafka-logs

在解压目录下,执行以下命令。目录里有 bin 目录

3.3 启动 zookeeper 服务

binwindowszookeeper-server-start.bat configzookeeper.properties

3.4 启动 kafka 服务

binwindowskafka-server-start.bat configserver.properties

4 创建一个主题

binwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1

 5 使用如下命令查看创建的主题列表:

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

6 启动生产者:

binwindowskafka-console-producer.bat --broker-list localhost:9092 --topic test1

启动consumer:

binwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test1 --from-beginning

8 进行测试

 在 producer 终端输入字符串,在 consumer 终端可以看到所有的输入

原文地址:https://www.cnblogs.com/zhaopengcheng/p/9824546.html