千家信息网

kafka和zookeeper是怎么安装的

发表于:2025-11-20 作者:千家信息网编辑
千家信息网最后更新 2025年11月20日,小编给大家分享一下kafka和zookeeper是怎么安装的,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!kafka和zo
千家信息网最后更新 2025年11月20日kafka和zookeeper是怎么安装的

小编给大家分享一下kafka和zookeeper是怎么安装的,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!

kafka和zookeeper安装

编写 compose

  zookeeper:    image: wurstmeister/zookeeper    ports:      - "2181:2181"  kafka:    image: wurstmeister/kafka    volumes:        - ./data/etc/localtime:/etc/localtime        - ./data/var/run/docker.sock:/var/run/docker.sock    ports:      - "9092:9092"    environment:      KAFKA_ADVERTISED_HOST_NAME: 192.168.110.147   ## 宿主机IP      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181      KAFKA_ADVERTISED_PORT: 9092  kafka-manager:    image: sheepkiller/kafka-manager    environment:        ZK_HOSTS:  192.168.110.147                  ## zookeeper地址    ports:      - "9091:9000"                                 # 宿主机port:container_port

开始安装

luwei@luweideMacBook-Pro-2 lnmp % docker-compose up -d zookeeperPulling zookeeper (wurstmeister/zookeeper:)...latest: Pulling from wurstmeister/zookeepera3ed95caeb02: Pull completeef38b711a50f: Pull completee057c74597c7: Pull complete666c214f6385: Pull completec3d6a96f1ffc: Pull complete3fe26a83e0ca: Pull complete3d3a7dd3a3b1: Pull completef8cc938abe5f: Pull complete9978b75f7a58: Pull complete4d4dbcc8f8cc: Pull complete8b130a9baa49: Pull complete6b9611650a73: Pull complete5df5aac51927: Pull complete76eea4448d9b: Pull complete8b66990876c6: Pull completef0dd38204b6f: Pull completeDigest: sha256:7a7fd44a72104bfbd24a77844bad5fabc86485b036f988ea927d1780782a6680Status: Downloaded newer image for wurstmeister/zookeeper:latestCreating lnmp_zookeeper_1 ... doneluwei@luweideMacBook-Pro-2 lnmp % docker-compose up -d kafkalnmp_kafka_1 is up-to-dateluwei@luweideMacBook-Pro-2 lnmp % docker-compose up -d kafka        Starting lnmp_kafka_1 ... done

查看安装结果

luwei@luweideMacBook-Pro-2 ~ % docker psCONTAINER ID   IMAGE                                                  COMMAND                  CREATED          STATUS                            PORTS                                                NAMES28a2a3b33856   sheepkiller/kafka-manager                              "./start-kafka-manag…"   3 minutes ago    Up 3 minutes                      0.0.0.0:9091->9000/tcp                               lnmp_kafka-manager_1d6ae300116f3   wurstmeister/zookeeper                                 "/bin/sh -c '/usr/sb…"   9 minutes ago    Up 8 minutes                      22/tcp, 2888/tcp, 3888/tcp, 0.0.0.0:2181->2181/tcp   lnmp_zookeeper_1c9de041d5ace   wurstmeister/kafka                                     "start-kafka.sh"         15 minutes ago   Up 4 seconds                      0.0.0.0:9092->9092/tcp                               lnmp_kafka_192b5e1563062   mysql:5.7.16                                           "docker-entrypoint.s…"   2 weeks ago      Up 6 hours                        0.0.0.0:3307->3306/tcp                               my_mysql5729f0b85f1284   registry.cn-hangzhou.aliyuncs.com/helowin/oracle_11g   "/bin/sh -c '/home/o…"   3 weeks ago      Up 6 hours                        0.0.0.0:1521->1521/tcp                               oracle89c169b8bd14   nginx:alpine                                           "/docker-entrypoint.…"   4 weeks ago      Up 6 hours (healthy)              0.0.0.0:81->80/tcp, 0.0.0.0:444->443/tcp             nginxe0e4fa4bf177   lnmp_php72                                             "entrypoint php-fpm"     4 weeks ago      Up 6 hours (healthy)              9000-9001/tcp                                        php72a1ddf67627cd   lnmp_php56                                             "entrypoint php-fpm"     4 weeks ago      Up 6 hours (healthy)              9000/tcp                                             php56324aa6c8b071   lnmp_php71                                             "entrypoint php-fpm"     4 weeks ago      Up 6 hours (healthy)              9000/tcp                                             php714fd5d2ce7612   mongo:4.4.0                                            "docker-entrypoint.s…"   4 weeks ago      Up 6 hours                        0.0.0.0:27018->27017/tcp                             mongo4.4f212f81e0546   redis:4-alpine                                         "docker-entrypoint.s…"   4 weeks ago      Up 6 hours (healthy)              0.0.0.0:6379->6379/tcp                               redise42962aa16c8   mysql:5.6                                              "docker-entrypoint.s…"   4 weeks ago      Restarting (137) 50 seconds ago                                                        mysqlluwei@luweideMacBook-Pro-2 ~ %

连接 kafka 容器

luwei@luweideMacBook-Pro-2 ~ % docker exec -it lnmp_kafka_1 /bin/bashbash-5.1#

创建 topic

bash-5.1# find / -name kafka-topics.sh/opt/kafka_2.13-2.7.1/bin/kafka-topics.shbash-5.1# /opt/kafka_2.13-2.7.1/bin/kafka-topics.sh --create --zookeeper 192.168.110.147:2181 --replication-factor 1  --partitions 1 --topic testCreated topic test.bash-5.1#

查看创建的主题

bash-5.1# /opt/kafka_2.13-2.7.1/bin/kafka-topics.sh --list --zookeeper 192.168.110.147:2181testbash-5.1#

启动生产者

bash-5.1# find / -name kafka-console-producer.sh/opt/kafka_2.13-2.7.1/bin/kafka-console-producer.shbash-5.1# /opt/kafka_2.13-2.7.1/bin/kafka-console-producer.sh --broker-list 192.168.110.147:9092 --topic mykafka>hello donglei[2021-11-22 08:05:19,506] WARN [Producer clientId=console-producer] Error while fetching metadata with correlation id 3 : {mykafka=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)>

启动消费者

bash-5.1# /opt/kafka_2.13-2.7.1/bin/kafka-console-consumer.sh --bootstrap-server 192.168.110.147:9092 --topic mykafka --from-beginninghello donglei

以上是"kafka和zookeeper是怎么安装的"这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注行业资讯频道!

篇文章 内容 宿主 宿主机 不怎么 主题 地址 大部分 容器 更多 消费者 生产者 知识 结果 行业 资讯 资讯频道 频道 参考 学习 数据库的安全要保护哪些东西 数据库安全各自的含义是什么 生产安全数据库录入 数据库的安全性及管理 数据库安全策略包含哪些 海淀数据库安全审计系统 建立农村房屋安全信息数据库 易用的数据库客户端支持安全管理 连接数据库失败ssl安全错误 数据库的锁怎样保障安全 宝塔怎么连接远程数据库 ff14豆豆柴服务器名字 亚马逊在中国的服务器也要备案吗 服务器管理口连不上 数据库去掉数前的0 建筑软件开发的前景如何 徐汇区管理网络技术服务多少钱 网络安全法第四十四条是什么 网络安全和java哪个易学 海康 视频管理服务器 网络安全打防管控建 基于已有数据库分析 网络安全小达人手抄报图片 怎么关闭服务器增强的安全 互联网根服务器关闭会怎样 软件开发行业的商业模式 福建冠丰互联网科技有限公司 数据库快捷方式被删除 湖北企业软件开发多少钱 服务器安什么安全软件下载 开展社区网络安全宣传工作简报 宝塔怎么连接远程数据库 软件开发公司实训 顺义区进口软件开发规定 可变剪切数据库 php服务器软件 郴州市学it软件开发培训多少钱 怎样评价软件开发方法的优劣 河北软件开发小程序 hp服务器默认管理ip多少
0