Kafka2.2.0 集群搭建

Zookeeper集群安装参考：

Zookeeper集群安装

Kafka2.2.0 集群

• 集群规划 node01、node02、node03部署Kafka2.2.0

• 解压

  tar -zxvf kafka_2.12-2.2.0.tgz
  

• 配置

  # 创建日志文件存放目录
  mkdir -p /opt/data/kafka/logs
  
  # 进入配置文件夹
  cd /usr/local/software/kafka_2.12-2.2.0/config
  
  # 修改 server.properties 文件
  # 集群中的 broker id是唯一的， 如这里是 node01 服务器  那么我这把吧id设置为 1 ， node02 的话 设置为 2
  broker.id=0
  # 删除topic功能使用 直接在文件夹空位置加上
  delete.topic.enable=true
  # 修改kafka运行日志存放路径
  log.dirs=/opt/data/kafka/logs
  # 配置Zookeeper 集群地址
  zookeeper.connect=node01:2181,node02:2181,node03:2181
  
  #设置环境变量  vi /etc/profile
  export KAFKA_HOME=/usr/local/software/kafka_2.12-2.2.0
  export PATH=$PATH:$KAFKA_HOME/bin
  
  #加载配置 source /etc/profile
  

• 复制到其他服务器上 注意修改
  
  broker.id
  
  的值

   scp -r /usr/local/software/kafka_2.12-2.2.0 root@node03:/usr/local/software/kafka_2.12-2.2.0
  

• 启动kafka

  $ nohup kafka-server-start.sh /usr/local/software/kafka_2.12-2.2.0/config/server.properties 1>/dev/null 2>&1 &