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