linux快速搭建kafka教程文档

版权声明:本文为作者原创文章,转载请附上原文出处链接和本声明。
本文链接:https://www.weijc.cn/jdetail/1589184919588

安装Kafka

wget http://mirror.bit.edu.cn/apache/kafka/2.2.2/kafka_2.12-2.2.2.tgz
tar -xf kafka_2.12-2.2.2.tgz
mv kafka_2.12-2.2.2 kafka

修改配置文件

vim server.properties
增加:lsteners=PLAINTEXT://:9092

启动zookeeper

(如果要后台启动 加上 nohup即可)

bin/zookeeper-server-start.sh config/zookeeper.properties
后台运行:
nohup /data/soft/kafka/bin/zookeeper-server-start.sh /data/soft/kafka/config/zookeeper.properties &

启动kafka

(如果要后台启动 加上 nohup即可)

bin/kafka-server-start.sh config/server.properties
后台运行:
nohup /data/soft/kafka/bin/kafka-server-start.sh /data/soft/kafka/bin/config/server.properties &

生产一个TOPIC

(在kafka的bin目录下运行)

./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test

消费一个TOPIC

(在kafka的bin目录下运行)

./kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test

查看所有的topic

bin/kafka-topics.sh --list --zookeeper localhost:2181

 

展开阅读全文
还能输入1000个字符