docker kafka 安装使用和可视化面板CMAK_cmak docker

一、下载镜像

docker pull zookeeper
docker pull wurstmeister/kafka

二、先启动zookeeper

#单机方式
docker run -d --name docker_zookeeper -p 2181:2181 -t zookeeper

三、再启动kafka

# 单机方式
docker run -d --name docker_kafka \
-p 9092:9092 \
-e KAFKA_BROKER_ID=0 \
-e KAFKA_ZOOKEEPER_CONNECT=192.168.58.132:2181 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.58.132:9092 \
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka

参数的192.168.58.132按实际情况改为宿主机器的IP地址，如果不这么设置，可能会导致在别的机器上访问不到kafka。

四、创建一个topic

# 进入容器
docker exec -it ${CONTAINER ID} /bin/bash
cd opt/kafka
# 单机方式：创建一个主题
bin/kafka-topics.sh --create --zookeeper 192.168.58.132:2181 --replication-factor 1 --partitions 1 --topic mykafka

此处不创建也可以，kafka默认是自动创建topic，当你尝试发送到topic或订阅topic时，会自动创建topic

五、发送消息

# 运行一个生产者
bin/kafka-console-producer.sh --broker-list 192.168.58.132:9092 --topic mykafka

六、接收消息

# 运行一个消费者
bin/kafka-console-consumer.sh --bootstrap-server 192.168.58.132:9092 --topic mykafka --from-beginning

七、下载、安装可视化工具CMAK(Cluster Manager for Apache Kafka)

docker pull vimagick/cmak
 
docker run -p 9000:9000 -e ZK_HOSTS="192.168.58.132:2181" --name docker_cmak -d vimagick/cmak

访问 http://192.168.58.132:9000/ 后, 右上角 Cluster->add Cluster添加一个集群.

完成后可以进入集群查看信息.