docker——kafka集群安装

docker——kafka集群安装

本文主要介绍如何在docker中搭建kafka集群。

1、下载kafka镜像：
docker pull wurstmeister/kafka

2、编写docker-compose.yml文件

version: '2'
services:
kafka:
build: .
image: wurstmeister/kafka
ports:
- "39094:9092"
environment:
KAFKA_ADVERTISED_HOST_NAME: 192.168.0.66
KAFKA_ADVERTISED_PORT: 9092
KAFKA_CREATE_TOPICS: "test:1:1"
KAFKA_ZOOKEEPER_CONNECT: 192.168.0.66:62181,192.168.0.66:62182,192.168.0.66:62183
volumes:
- /var/run/docker.sock:/var/run/docker.sock

需要注意的是这里的KAFKA_ADVERTTISED_PORT:9092如果没有进行设置，会报错。
使用命令启动kafka：
docker-compose up -d

3、查看docker中kafka的状态：
docker ps -a

4、如果发现kafka没有启动， 可以都能通过命令查看日志。
docker logs containedID

5、扩展成集群(首先需要修改端口，不然会出现端口已经被占用)：
docker-compose scale kafka=2 

6、再次修改端口，添加主机：
docker-compose scale kafka=3

7、查看状态。
docker ps - a