kafka和zookeeper是怎么安装的
发表于:2024-09-30 作者:千家信息网编辑
千家信息网最后更新 2024年09月30日,小编给大家分享一下kafka和zookeeper是怎么安装的,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!kafka和zo
千家信息网最后更新 2024年09月30日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安全错误
数据库的锁怎样保障安全
方舟服务器隐藏管理员代码
百秋电商软件开发怎么样
合肥万户网络技术有限公司
网络安全5g龙头
大数据数据库db2
苏州阿里云服务器功能简介
计算机类含计算机网络技术专业
bing找不到服务器ip地址
服务器最高管理员账号
江苏新丰合网络技术有限公司
互联网科技增值税
安徽常用软件开发怎么样
萌百服务器
石龙手机软件开发
超星慕课计算机网络技术
在数据库创建登陆用户
还原数据库提示操作系统错误
飞猪购买机票显示服务器错误
软件开发完成一直使用不付款
mc创建服务器手机
it与网络技术的发展
数据库dx表是什么表
服务器主板开机一会就会掉电
荣昌区工商软件开发流程特点
贵州销售软件开发排行榜
光明分局开展网络安全宣传
2u服务器高度
网络安全管理系统建设方案
小学数据库怎么写
软件开发薪酬里包不包含加班费