Kafka(0.10.0.1)--配置Zookeeper和单节点多brokers

时间:2022-01-01 22:02:14

Kafka(0.10.0.1)–配置Zookeeper和单节点多brokers

官方参考文档,版本(kafka_0.10.0.X): http://kafka.apache.org/0100/documentation.html

  • zookeeper-3.4.9

    1. 下载压缩包并解压

      tar -zxvf zookeeper-3.4.9.tar.gz

    2. 配置参数
      zoo.cfg配置如下图:
      Kafka(0.10.0.1)--配置Zookeeper和单节点多brokers

      参数解释:

      参数 说明
      tickTime zookeeper服务器与客户端之间维护心跳的时间间隔
      initLimit 集群模式下,Follower机器启动,需要从Leader上同步最新数据,来确定自身服务状态,同步需要在initLimit内完成。即同步时间为10 * 2000 = 20 s(initLimit*tickTime)
      syncLimit 集群模式下,Leader需要与集群中的其他机器Follower进行通信,则通过心跳机制来检测Follower状态,如果超过心跳间隔syncLimit,则表示该Follower下线。心跳时间间隔为 5 * 2000 = 10s(syncLimit * tickTime)
      dataDir 保存zookeeper数据的目录

      ps:

      • 单机版zookeeper则不需要关注initLimit和syncLimit
    3. 启动Zookeeper
      转到/bin目录下,使用刚配置好的zoo.cfg配置,去启动zookeeper。命令如下:

      ./zkServer.sh start ../conf/zoo.cfg

  • kafka_2.10-0.10.0.1

    1. 解压压缩包

      tar -zxvf kafka_2.10-0.10.0.1.tgz

    2. 参数配置
      需要修改的参数项,其他可保持默认值

      参数 说明
      broker.id 每个kafka实例的id必须用唯一非负整数id进行标识
      listeners 客户端连接服务端的地址和端口, kafka实例并监听这个端口例:listeners=PLAINTEXT://c13-141:9092
      log.dirs kafka日志目录
      zookeeper.connect kafka连接zookeeper的地址和端口,例:zookeeper.connect =localhost:2181
    3. 启动kafka
      转到/bin目录下,使用nohup后台启动kafka,会在bin目录下生成nohup.out日志文件,其中包含了kafka启动日志

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