Docker中使用Apache Kafka
目录
参考wurstmeister/kafka-docker项目
尝试将最简单的Kafka配置放入Docker中,需要两个容器:一个运行zookeeper,一个运行Kafka。
Zookeeper
最简单的zookeeper使用方法就是使用将conf/zoo_sample.cfg配置文件复制为zoo.cfg,执行bin/zkServer.sh start-foreground,启动zookeeper。
Dockerfile
Kafka
Kafka在本机环境下不需要设置就可以直接使用,但Docker中必须设置zookeeper服务器的ip地址,并且设置advertised host name,否则pykafka客户端无法连接到kafka服务器上。
Dockerfile
运行
zookeeper
kafka
启动后需要一些配置,则可以通过shell连接kafka
如设置话题
总结
这只是最简单的Kafka使用方式,实际应用中Zookeeper和Kafka都应该部署在集群中,就无法使用现在的Dockerfile,后面有待改进。
Github项目 perillaroc/kafka-docker