千家信息网

kafka和zookeeper是怎么安装的

发表于:2026-11-03 作者:千家信息网编辑
千家信息网最后更新 2026年11月03日,小编给大家分享一下kafka和zookeeper是怎么安装的,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!kafka和zo
千家信息网最后更新 2026年11月03日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安全错误 数据库的锁怎样保障安全 山东特亿宝互联网科技有限公司 互联网和科技技术 圆梦互联网科技 港股互联网科技股 互联网科技的 互联网 科技公司 金融科技与互联网金融 小马过河互联网科技 致聘互联网科技 广西拼得多互联网科技有限公司 青岛中康互联网医疗科技有限公司 互联网科技博主是什么意思 金融科技与互联网金融相同和不同 成都铂石互联网科技做什么的 千方科技属于互联网企业吗 辽宁互联网新科技 深圳育鹏互联网科技有限公司招聘 互联网科技和法律行业 富国互联网金融科技混合基金 陕西九四连强互联网科技有限公司 互联网科技公司排名 善班互联网科技 广州互联网络科技有限公司 恒生科技互联网指数分析 广州慧亚互联网科技怎么样 开一家科技互联网公司需要多少钱 佛山市拉法互联网科技有限公司 元气玛特互联网科技公司是外包吗 信承诺互联网科技有限公司 互联网 科技节活动 微视频大赛
0