30.Docker部署Kafka集群

Docker部署Kafka集群

安装zookeeper

docker run -d \
--name zookeeper \
-p 2181:2181 \
-t wurstmeister/zookeeper

安装Kafka集群

kafka0

docker run -d --name kafka0 -p 9092:9092 \
-e KAFKA_BROKER_ID=0 \
-e KAFKA_ZOOKEEPER_CONNECT=81.68.232.188:2181 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://81.68.232.188:9092 \
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \
-t wurstmeister/kafka

kafka1

docker run -d --name kafka1 -p 9093:9093 \
-e KAFKA_BROKER_ID=1 \
-e KAFKA_ZOOKEEPER_CONNECT=81.68.232.188:2181 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://81.68.232.188:9093 \
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9093 \
-t wurstmeister/kafka

kafka2

docker run -d --name kafka2 -p 9094:9094 \
-e KAFKA_BROKER_ID=2 \
-e KAFKA_ZOOKEEPER_CONNECT=81.68.232.188:2181 \
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://81.68.232.188:9094 \
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9094 \
-t wurstmeister/kafka

docker ps

创建1主题2分区3备份

docker exec -it kafka0 bash

cd /opt/kafka/bin/

#创建主题
./kafka-topics.sh --create \
--zookeeper 81.68.232.188:2181 \
--replication-factor 3 --partitions 2 \
--topic test

#查看主题详情
./kafka-topics.sh  \
--zookeeper 81.68.232.188:2181 \
--describe \
--topic test

来源：https://blog.csdn.net/weixin_41405524/article/details/129002038