写点什么

Windows10 Kafka Docker 集群搭建

用户头像
关注
发布于: 2021 年 01 月 10 日

Windows10 Kafka Docker 集群搭建




简介


    使用 Windows Docker Desktop 搭建 Kafka 集群


运行 Zookeeper


    这里使用但 zk,使用 docker 启动即可


# 第一次启动docker run -dit --name zk -p 2181:2181 zookeeper
# 重启docker restart zk
# 查看日志docker logs -f zk
复制代码


运行 Kafka


    启动的命令如下,注意将下面的 192.168.101.104 换成自己的宿主机 IP,运行后查看日志正常即可


# 第一次启动docker run -dit --name kafka0 -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.101.104:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.101.104:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka
docker run -dit --name kafka1 -p 9093:9093 -e KAFKA_BROKER_ID=1 -e KAFKA_ZOOKEEPER_CONNECT=192.168.101.104:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.101.104:9093 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9093 -t wurstmeister/kafka
docker run -dit --name kafka2 -p 9094:9094 -e KAFKA_BROKER_ID=2 -e KAFKA_ZOOKEEPER_CONNECT=192.168.101.104:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.101.104:9094 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9094 -t wurstmeister/kafka
# 重启docker restart kafka0docker restart kafka1docker restart kafka2
# 查看日志docker logs -f kafka0
# 删除kafkadocker rm -f kafka0docker rm -f kafka1docker rm -f kafka2
复制代码


测试


    测试建立 3 的副本和 5 的 partition,查看是否配置成功。然后在 1 和 2 上启动消费者,0 生产消息


# 建立副本和partitiondocker exec -ti kafka0 kafka-topics.sh --create --zookeeper 192.168.101.104:2181 --replication-factor 3 --partitions 5 --topic TestTopic# 查看信息docker exec -ti kafka0 kafka-topics.sh --describe --zookeeper 192.168.101.104:2181 --topic TestTopicdocker exec -ti kafka1 kafka-topics.sh --describe --zookeeper 192.168.101.104:2181 --topic TestTopicdocker exec -ti kafka2 kafka-topics.sh --describe --zookeeper 192.168.101.104:2181 --topic TestTopic
# 消费和生产,最后一个kafka0输出后在其他两个能看到docker exec -ti kafka1 kafka-console-consumer.sh --bootstrap-server 192.168.101.104:9093 --topic TestTopic --from-beginningdocker exec -ti kafka2 kafka-console-consumer.sh --bootstrap-server 192.168.101.104:9094 --topic TestTopic --from-beginningdocker exec -ti kafka0 kafka-console-producer.sh --broker-list 192.168.101.104:9092 --topic TestTopic
# 性能测试docker exec -ti kafka0 kafka-producer-perf-test.sh --topic TestTopic --num-records 100000 --record-size 1000 --throughput 2000 --producer-props <span id="instant-markdown-cursor"></span>bootstrap.servers=192.168.101.104:9092docker exec -ti kafka0 kafka-consumer-perf-test.sh --bootstrap-server 192.168.101.104:9092 --topic TestTopic --fetch-size 1048576 --messages 100000 --threads 1
复制代码


kafka manage


    使用 docker 启动后,访问: http://localhost:9000/ , 点击添加 cluster,输入前两个(名称和 zk 地址),保存即可


docker run -dit -p 9000:9000 -e ZK_HOSTS="192.168.101.104:2181" hlebalbau/kafka-manager:stable
http://localhost:9000/
复制代码


参考链接



发布于: 2021 年 01 月 10 日阅读数: 92
用户头像

关注

还未添加个人签名 2018.09.09 加入

代码是门手艺活,也是门艺术活

评论

发布
暂无评论
Windows10 Kafka Docker 集群搭建