前言
kafka要和ZooKeeper、jdk配合使用,所以要先安装jdk和zookeeper
安装 ZooKeeper
1.zookeeper下载地址
https://zookeeper.apache.org/releases.html#download
2.同版本下有两个下载包,下载红色框标注的包
3.因为是tar.gz包,所以解压两次如图: 把整个目录拷贝到自己工作的盘符下 4.打开zookeeper目录,新建两个文件夹 log 和 data
5.打开conf文件夹 将“zoo_sample.cfg”重命名为“zoo.cfg” 打开“zoo.cfg”找到并且编辑 dataDir=E:\zookeeper\apache-zookeeper-3.5.9-bin\data 在添加一个日志路径 dataLogDir=E:\zookeeper\apache-zookeeper-3.5.9-bin\log (注意我的在E盘zookeeper下,路径改成自己的目录) 6.添加zookeeper到环境变量中
7.打开cmd,输入 zkServer 运行Zookeeper 此窗口不要关闭,接下来的kafka需要用到
安装kafka
1.kafka下载地址
https://kafka.apache.org/downloads
2.下载解压完如图(放到自己工作的盘符目录下,我的在E:kafka下) 3.进入config目录找到文件server.properties打开, 找到并且修改 log.dirs=E:\kafka\kafka_2.13-2.8.0\logs 4 Zookeeper端口默认2181),kafka文件里面zookeeper的连接设置默认端口也是2181不用修改 Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181 到此kafka安装完毕
5 进入到kafka安装目录 E:\kafka\kafka_2.13-2.8.0 ,然后Shift+鼠标右键,打开Powershell窗口
6 在窗口输入下面的值启动kafka(zookeeper服务必须启动中,安装zookeeper步骤中有启动步骤)
.\bin\windows\kafka-server-start.bat .\config\server.properties
测试生产者和消费者通信
- 创建topictest主题,进入kafka目录 E:\kafka\kafka_2.13-2.8.0,然后 Shift+鼠标右键,打开Powershell窗口 输入如下值:
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topictest
目前为止应该有3个命令行窗口
2.创建生产者,进入kafka目录 E:\kafka\kafka_2.13-2.8.0,然后 Shift+鼠标右键,打开Powershell窗口 输入如下值 并回车:
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic topictest
3.创建消费者,进入kafka目录 E:\kafka\kafka_2.13-2.8.0,然后 Shift+鼠标右键,打开Powershell窗口 输入如下值 并回车:
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic topictest --from-beginning
4.输入测试英文查看通信, 在生产者(producer.bat)窗口 输入英文值测试,输入完值回车一下,消费者窗口同步出现值 消费者窗口会出现同样的值,测试OK!
- 窗口解释:现在我们得任务栏有5个窗口,第一个是zookeeper的服务启动,第二个是kafka的服务启动 ,第三个是创建kafka的主题, 第四个是生产者,第五个是消费者
spirngboot集成kafka (请看我的另一篇博客)
https://blog.csdn.net/zhanghengchao123/article/details/122150066
|