需要注意帮 DOCKER_HOST_IP 配置成外部可以访问你容器的ip地址,直接修改DOCKER_HOST_IP或者后面的 127.0.0.1都可以。如果这个不修改,外部访问你这个kafka可能会有问题。 参考资料: https://gi…
Leave a Comment分类: kafka
最近要实现一个基于kafka的流数据处理,需要一个本地的kafka开发环境,有一些在线的测试数据。 项目结构: main.py config.ini Dockerfile docker-compose.yml 编译好镜像直接运行即可,配置指…
Leave a Comment主要是用 kafka-consumer-groups.sh 这个指令。 –bootstrap-server localhost:9092 –group consumerGroupId 主要是指定要操作的集群和消费者组, –d…
Leave a Comment服务器准备 我这边准备了3台服务器,分别是172.26.130.15、172.26.130.16、172.26.130.17,都是装的centos7的系统,防火墙都关闭了。 配置zookeeper 下载zookeeper https://z…
Leave a Comment