系统:centOS7
kafka安装包版本:kafka_2.11-0.11.0.0.tgz
1.在opt目录下创建module目录,
2.将kafka解压到module目录下:
tar -zxvf kafka_2.11-0.11.0.0.tgz -C /opt/module
3.在解压后的kafka根目录下创建logs目录
4.vim编辑模式下修改config目录下的server.properties配置文件
修改配置文件的broker.id,第一台取值为0,第二台取值为1,第三台取值为2,依次类推。
允许删除主题的配置改为true
每一台的监听配置改为本机ip地址:
修改数据目录为上面创建的data目录:
修改zookeeper连接地址为自己的zk集群地址:
5.启动kafka
依次启动每一台kafka:
bin/kafka-server-start.sh config/server.properties
6.测试:
生产者:
bin/kafka-console-producer.sh –broker-list 192.168.242.129:9092 –topic first
消费者:
bin/kafka-console-consumer.sh –bootstrap-server 192.168.242.131:9092 –topic first