修改Kafka配置文件

Kafka所有的配置文件都在“$KAFKA_HOME/config”目录下,修改以下配置文件前,需要切换到“$KAFKA_HOME/config”目录。
1 | cd $KAFKA_HOME/config |
- 修改server.properties文件。
- 打开文件。
1
vi server.properties
- 按“i”进入编辑模式,内容修改如下。
1 2 3 4 5
broker.id=0 port=6667 host.name=agent1 log.dirs=/data/data1/kafka,/data/data2/kafka,/data/data3/kafka,/data/data4/kafka,/data/data5/kafka,/data/data6/kafka,/data/data7/kafka,/data/data8/kafka,/data/data9/kafka,/data/data10/kafka,/data/data11/kafka,/data/data12/kafka zookeeper.connect=agent1:2181,agent2:2181,agent3:2181
其中,参数host.name可填写agent1对应的IP地址,log.dirs为实际的存储数据路径。
- 按“Esc”键,输入:wq!,按“Enter”保存并退出编辑。
- 打开文件。
- 同步配置到其它节点。
- 拷贝kafka_2.11-0.10.1.1到agent2、3的“/usr/local”目录下。
1 2
scp -r /usr/local/kafka_2.11-2.2.0 root@agent2:/usr/local scp -r /usr/local/kafka_2.11-2.2.0 root@agent3:/usr/local
- 登录到agent2、agent3节点,为kafka_2.11-2.2.0建立软链接。
1 2
cd /usr/local ln -s kafka_2.11-2.2.0 kafka
- 拷贝kafka_2.11-0.10.1.1到agent2、3的“/usr/local”目录下。
- 修改节点相关参数。
- 登录agent2,修改server.properties。
1
vi server.properties
- 按“i”进入编辑模式,内容修改如下。
1 2
broker.id=1 host.name=agent2 #可填对应的IP地址
- 按“Esc”键,输入:wq!,按“Enter”保存并退出编辑。
- 登录agent3,修改server.properties。
1
vi server.properties
- 按“i”进入编辑模式,内容修改如下。
1 2
broker.id=2 host.name=agent3 #可填对应的IP地址
- 按“Esc”键,输入:wq!,按“Enter”保存并退出编辑。
- 登录agent2,修改server.properties。
父主题: 部署Kafka