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多少