Docker 搭建kafka和zookeeper以及分区处理 |
您所在的位置：网站首页 › ps4怪物猎人世界太刀登龙斩怎么用 › Docker 搭建kafka和zookeeper以及分区处理 |
Docker 搭建kafka和zookeeper以及分区处理
|
首先对于kafka和zookeeper搭建请详细看下http://blog.70ci.com/post/736.html 转载请注明：WX技术博客 » Docker搭建kafka和zookeeper 文章亲测没有问题并且分区是在此基础上的 1.创建zookeeper docker run -d --name zookeeper -p 2181:2181 -t zookeeper 2.创建三个节点 分别建立三个容器:(前提是保证zookeeper是启动状态)docker run -d --name kafka -p 9094:9094 -e KAFKA_BROKER_ID=1 -e KAFKA_ZOOKEEPER_CONNECT=192.168.9.13:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.0.102:9094 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9094 -t wurstmeister/kafkadocker run -d --name kafka1 -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.9.13:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.0.102:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafkadocker run -d --name kafka2 -p 9093:9093 -e KAFKA_BROKER_ID=2 -e KAFKA_ZOOKEEPER_CONNECT=192.168.9.13:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.0.102:9093 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9093 -t wurstmeister/kafka/* 主要修改参数: KAFKA_BROKER_ID=0 KAFKA_ZOOKEEPER_CONNECT=192.168.9.13:2181 //自己本机ipKAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.9.13:9092KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 */3.创建万以后 docker ps 查看容器列表
4.进入 容器id为:c807218a4c31的kafka里面: (1).docker exec -it c807218a4c31 /bin/bash (2).cd opt (3). cd kafka_2.13-2.7.0/ 5.创建主题:topics名字叫topic2;3个分区、2个副本 bin/kafka-topics.sh --zookeeper 192.168.9.13:2181 --topic topic2 --create --replication-factor 2 --partitions 3 6.最后查看创建的结果 bin/kafka-topics.sh --zookeeper 192.168.9.13:2181 --topic topic2 --describe
出现图片1中的结果证明第5步骤成功.出现图片2中的结果则节点创建成功 7.创建生产者 bin/kafka-console-producer.sh --broker-list 192.168.9.13:9092 --topic topic28.新建消费者 bin/kafka-console-consumer.sh --bootstrap-server192.168.9.13:9092 --topic topic2 --from-beginning ps:可能在整理的过程中有的地方说的不对希望各位路过的大神提出来指导我改正下因为是刚刚接触所以不是太能理解所以这里记录下笔记 |
【本文地址】
今日新闻 |
推荐新闻 |