3台虚拟机搭建kafka集群

系统:centOS7

kafka安装包版本:kafka_2.11-0.11.0.0.tgz

1.在opt目录下创建module目录,

《3台虚拟机搭建kafka集群》

2.将kafka解压到module目录下:

tar -zxvf kafka_2.11-0.11.0.0.tgz -C /opt/module

3.在解压后的kafka根目录下创建logs目录

《3台虚拟机搭建kafka集群》

4.vim编辑模式下修改config目录下的server.properties配置文件

修改配置文件的broker.id,第一台取值为0,第二台取值为1,第三台取值为2,依次类推。

《3台虚拟机搭建kafka集群》

允许删除主题的配置改为true

《3台虚拟机搭建kafka集群》

每一台的监听配置改为本机ip地址:

《3台虚拟机搭建kafka集群》

修改数据目录为上面创建的data目录:

《3台虚拟机搭建kafka集群》

修改zookeeper连接地址为自己的zk集群地址:

《3台虚拟机搭建kafka集群》

5.启动kafka

依次启动每一台kafka:

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

《3台虚拟机搭建kafka集群》

6.测试:

生产者:

bin/kafka-console-producer.sh –broker-list 192.168.242.129:9092 –topic first

《3台虚拟机搭建kafka集群》

 

消费者:

bin/kafka-console-consumer.sh –bootstrap-server 192.168.242.131:9092 –topic first

《3台虚拟机搭建kafka集群》

 

    原文作者:qian言wan语
    原文地址: https://blog.csdn.net/sungaochao/article/details/109584699
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞