docker 安装kafka

使用bitnami镜像：

$ curl -sSL https://raw.githubusercontent.com/bitnami/bitnami-docker-kafka/master/docker-compose.yml > docker-compose.yml
$ docker-compose up -d

启动zookeeper容器：

docker run -d \
--name zookeeper \
-p 2181:2181 \
-e ALLOW_ANONYMOUS_LOGIN=yes \
bitnami/zookeeper:latest

启动kafka容器：

podman run -d \
--name kafka \
-e ALLOW_PLAINTEXT_LISTENER=yes \
-e KAFKA_CFG_ZOOKEEPER_CONNECT=192.168.56.100:2181 \
-p 9092:9092 \
bitnami/kafka:latest

使用wurstmeister镜像：

启动zookeeper容器：

docker run -d \
--name zookeeper \
--restart=always \
-p 2181:2181 \
wurstmeister/zookeeper

启动kafka容器：

docker run -d --name kafka \
--restart=always \
-p 9092:9092 \
--link zookeeper \
-e KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \
-e KAFKA_ADVERTISED_HOST_NAME=192.168.2.200 \
-e KAFKA_ADVERTISED_PORT=9092 \
wurstmeister/kafka

验证kafka，进入容器:

docker exec -it kafka /bin/bash

创建生产者：

kafka-console-producer.sh -broker-list 127.0.0.1:9092 -topic testTopic

创建消费者：

kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 -topic testTopic

保持上面的生产者和消费者在运行状态，在生产者命令行上输入文本回车后，消费者可以看到输出 。

查看主题：

kafka-topics.sh -list --bootstrap-server 127.0.0.1:9092

参考：

bitnami/kafka