欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

kafka单机版部署文档(linux)

程序员文章站 2022-05-27 17:05:42
...

一、下载kafka2.10的包(kafka自带zookeeper,所以无需单独安装zookeeper)

请切换到自己kafka的安装目录再下载,我是在/usr/local/kafka下安装,没有此目录请新建。

wget http://labfile.oss.aliyuncs.com/courses/859/kafka_2.10-0.10.2.1.tgz

二、解压压缩包

tar -zxvf kafka_2.10-0.10.2.1.tgz
mv kafka_2.10-0.10.2.1 kafka

三、修改配置文件

切换到kafka/config目录下,修改配置文件server.properties

broker.id=0
port=9092
# 如果需要外网访问(例如java-api),必须有此项配置,将IP替换成本机的IP
listeners=PLAINTEXT://IP:9092
advertised.listeners=PLAINTEXT://IP:9092
zookeeper.connect=localhost:2181
log.dirs=/usr/local/logs/kafka

四、启动kafka

启动zookeeper(后台启动),再启动kafka(后台启动)

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
bin/kafka-server-start.sh -daemon config/server.properties

五、测试

开启两个客户端,一个作为peoducer一个作为consumer

# producer执行

bin/kafka-console-producer.sh --broker-list *.*.*.*:9092 --topic topic1

# consumer执行

bin/kafka-console-consumer.sh --bootstrap-server *.*.*.*:9092 --topic topic1 --from-beginning

producer发送消息,consumer可以接收到。

kafka单机版部署文档(linux)

kafka单机版部署文档(linux)

六、引用一个常见的问题以及修改方法 - Broker may not be available

https://blog.csdn.net/qq_40633152/article/details/81090306

相关标签: kafka