介绍kafka和zookeeper是如何安装的
导读:收集整理的这篇文章主要介绍了介绍kafka和zookeeper是如何安装的,觉得挺不错的,现在分享给大家,也给大家做个参考。本文由go语言教程栏目给大家介绍kafka和zookeePEr是如何安装的 ,希望对需要的朋友有所帮助!kafka和...
收集整理的这篇文章主要介绍了介绍kafka和zookeeper是如何安装的,觉得挺不错的,现在分享给大家,也给大家做个参考。本文由go语言教程栏目给大家介绍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是如何安装的的详细内容,更多请关注其它相关文章!
声明:本文内容由网友自发贡献,本站不承担相应法律责任。对本内容有异议或投诉,请联系2913721942#qq.com核实处理,我们将尽快回复您,谢谢合作!
若转载请注明出处: 介绍kafka和zookeeper是如何安装的
本文地址: https://pptw.com/jishu/619992.html