Kafka安装及配置
Kafka安装及配置
1、安装zookeeper
zookeeper安装具体参见:
https://whwtree.com/archives/kafka-install-config.html
2、下载Kafka安装包
kafka下载地址:
https://kafka.apache.org/downloads
下载Kafka最新版3.3.1版本,文件:kafka_2.12-3.3.1.tgz
如下图示:
3、解压缩,进入config目录修改server.properties配置
找到log.dirs配置并修改为:
log.dirs=D:\tools\kafka_2.12-3.3.1\logs
4、启动Kafka
(1)启动zookeeper服务端
进入Zookeeper安装目录D:\tools\apache-zookeeper-3.8.0-bin\bin目录,双击zkServer.cmd启动zookeeper服务端;
(2)启动kafka服务端
打开cmd,进入安装目录:D:\tools\kafka_2.12-3.3.1,输入以下命令启动:
.\bin\windows\kafka-server-start.bat .\config\server.properties
5、kafka测试
(1)创建主题
打开cmd窗口,进入安装目录,输入以下命令执行创建topic命令:
.\bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --topic test
说明:
直接输入.\bin\windows\kafka-topics.bat回车,可查看kafka-topics对应的参数说明,其他脚本同理;
创建完成后,输入以下命令查看主题:
.\bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092
(2)创建生产者并发送hello world!消息,打开一个新的cmd窗口,进入安装目录执行以下命令:
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
输入内容:hello world!
如下所示:
(3)创建消费者,打开一个新的cmd窗口,进入安装目录,输入以下命令:
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
可以看到,消费者可以正常接收到生产者发送的内容:hello world!
(完)