鲲鹏社区首页
中文
注册
我要评分
文档获取效率
文档正确性
内容完整性
文档易理解
在线提单
论坛求助

修改Kafka配置文件

Kafka所有的配置文件都在“$KAFKA_HOME/config”目录下,修改以下配置文件前,需要切换到“$KAFKA_HOME/config”目录。

1
cd $KAFKA_HOME/config
  1. 修改server.properties文件。
    1. 打开文件。
      1
      vi server.properties
      
    2. “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为实际的存储数据路径。

    3. “Esc”键,输入:wq!,按“Enter”保存并退出编辑。
  2. 同步配置到其它节点。
    1. 拷贝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
      
    2. 登录到agent2、agent3节点,为kafka_2.11-2.2.0建立软链接。
      1
      2
      cd /usr/local
      ln -s kafka_2.11-2.2.0 kafka
      
  3. 修改节点相关参数。
    1. 登录agent2,修改server.properties。
      1
      vi server.properties
      
    2. “i”进入编辑模式,内容修改如下。
      1
      2
      broker.id=1
      host.name=agent2 #可填对应的IP地址
      
    1. “Esc”键,输入:wq!,按“Enter”保存并退出编辑。
    2. 登录agent3,修改server.properties。
      1
      vi server.properties
      
    3. “i”进入编辑模式,内容修改如下。
      1
      2
      broker.id=2
      host.name=agent3 #可填对应的IP地址
      
    4. “Esc”键,输入:wq!,按“Enter”保存并退出编辑。