Docker安装kafka

Step 1: 安装

Kafka 使用 ZooKeeper 如果你还没有ZooKeeper服务器，我们需要安装ZooKeeper服务器。

拉去 ZooKeeper

docker pull zookeeper:latest

现在启动Kafka服务器：

docker run -d--name zookeeper --publish2181:2181 --volume /etc/localtime:/etc/localtime zookeeper:latest

安装Kafka

docker pull wurstmeister/kafka:latest

启动Kafka

docker run -d--name kafka -p9092:9092 -eKAFKA_BROKER_ID=0-eKAFKA_ZOOKEEPER_CONNECT=【ZooKeeper地址】:2181 -eKAFKA_ADVERTISED_LISTENERS=PLAINTEXT://【kafka地址】:9092 -eKAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka

Step 2: 进入容器

`docker exec -it ${CONTAINER ID} /bin/bash 

Step 3: 创建一个 topic

`cd /opt/kafka_** 

让我们创建一个名为“test”的topic，它有一个分区和一个副本：

`bin/kafka-topics.sh --create --zookeeper zookeeper服务的地址:2181 --replication-factor 1 --partitions 1 --topic test 

现在我们可以运行list（列表）命令来查看这个topic：

bin/kafka-topics.sh --list --zookeeper kafka地址:2181    

Step 4: 发送消息

bin/kafka-console-producer.sh --broker-list kafka地址:9092 --topic test 

Step 5: 启动一个 consumer

Kafka 还有一个命令行consumer（消费者），将消息转储到标准输出

bin/kafka-console-consumer.sh --bootstrap-server kafka地址:9092 --topic test --from-beginning 

官方文档：https://kafka.apachecn.org/