kafka安装启动集群搭建

https://kafka.apache.org/quickstart

• 安装 http://kafka.apache.org/downloads
• 解压缩 tar -zxvf kafka_2.12-3.0.0.tgz
• 编辑配置文件 vim config/server.properties

# 集群中当前broker唯一id
broker.id=0
# 换成自己电脑的ip
listeners=PLAINTEXT://localhost:9092
# 日志存放路径
log.dirs=../kafka-data-log/kafka-logs
默认的分区数
num.partitions=1
# 连接的zk地址
zookeeper.connect=localhost:2181

• 启动 bin/kafka-server-start.sh -daemon ../config/server.properties
• 检查是否启动
  • ps -aux |grep ../config/server.properties
  • ps -aux |grep kafka

  • 检查zk节点

    
    
    image.png

• 集群搭建

  • 复制3分kafka安装包

    
    
    image.png

  • 分别修改配置文件

    
    
    image.png

broker.id=0
listeners=PLAINTEXT://127.0.0.1:9092
log.dirs=../kafka-data-log/kafka-logs-0

broker.id=1
listeners=PLAINTEXT://127.0.0.1:9093
log.dirs=../kafka-data-log/kafka-logs-1

broker.id=2
listeners=PLAINTEXT://127.0.0.1:9094
log.dirs=../kafka-data-log/kafka-logs-2

• 分别启动

  
  
  image.png

• 检查是否启动成功

  
  
  image.png

• 可视化管理工具
  • https://github.com/didi/LogiKM
  • https://github.com/yahoo/CMAK