参考官方文档:quickstart
一、准备环境
centos7、jdk8
安装过程(略),关闭防火墙
二、安装kafka
下载安装包:下载地址
上传到/usr/local目录
-
解压文件
tar -zxvf kafka_2.12-2.8.0.tgz
-
修改监听地址,默认127.0.0.1
vim /usr/local/kafka_2.12-2.8.0/config
修改如下代码,替换为自己IP地址
listeners = PLAINTEXT://xxxx:9092
-
启动zookeeper,这里使用了自带的zookeeper
bin/zookeeper-server-start.sh config/zookeeper.properties
-
开启新的终端,启动kafka
bin/kafka-server-start.sh config/server.properties
-
开启新的终端,创建topic
bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server xxxx:9092
-
查看topic
bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server xxxx:9092
-
往topic写消息
bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server xxxx:9092
-
开启新的终端,读取topic的消息
bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server xxxx:9092