Kafka集群搭建

这里以3台节点为例

1.上传解压

上传到当前用户家目录下,解压到/opt目录下

2.配置  config/server.properties

cd /opt/kafka_2.11-0.11.0.3/conf目录下:vim server.properties

修改如下四个配置项,(0.11版本的kafka端口号默认是9092,可以不用修改)

broker.id当前节点的broker id

delete.topic.enable=true支持删除topic

配置zookeeper集群

这里拷贝启动kafka启动脚本到kafka目录下,

打开脚本内容如下:看不懂的可以参考链接;

Linux 里的 2>&1 究竟是什么 - 挖坑埋你 - CSDN博客

3.发送其他节点

4.启动zookeeper集群

分别在node01,node02,node03节点:zkServer.sh start;

为什么这里要拷贝kafka启动脚本到kafka目录下,因为如果使用kafka bin目录下的

kafka-server-start.sh 来启动的话,会阻塞式占用当前窗口,ctrl+c的话kafka进程会被杀死;

采用脚本方式提交的话就很好的避免了上述情况

5.分别在每台broker节点启动kafka