wget https://archive.apache.org/dist/kafka/2.8.0/kafka_2.13-2.8.0.tgz
mv kafka_2.13-2.8.0.tgz /usr/local
将文件移动至/usr/local目录下cd /usr/local
tar -zxvf kafka_2.13-2.8.0.tgz
进行解压
usr/local/kafka_2.13-2.8.0/config/server.properties
修改server.properties文件中以下配置项:#3台服务器的id分别为0,1,2
broker.id=0
# 地址后面/kafka是在建立zookeeper时创建的根目录,kafka相关的数据在此目录保存
zookeeper.connect=192.168.2.187:2181,192.168.1.228:2181,192.168.1.236:2181/kafka
# 192.168.2.187为本机ip
listeners=PLAINTEXT://192.168.2.187:9092
/usr/local/kafka_2.13-2.8.0/bin/
./kafka-server-start.sh ../config/server.properties
,启动成功后如下图
./kafka-topics.sh --zookeeper 192.168.2.187:2181,192.168.1.228:2181,192.168.1.236:2181/kafka --create --topic testtopic --partitions 3 --replication-factor 3
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。