jcnnghm/kafka

kafka-docker

Apache Kafka的Dockerfile，镜像可直接从https://registry.hub.docker.com/%E8%8E%B7%E5%8F%96%E3%80%82

前提条件

• 安装docker-compose：[***]
• 修改docker-compose.yml中的KAFKA_ADVERTISED_HOST_NAME以匹配Docker主机IP（注意：如果要运行多个broker，不要使用localhost或127.0.0.1作为主机IP）
• 如需自定义Kafka参数，只需在docker-compose.yml中添加环境变量，例如：要增加message.max.bytes参数，设置环境变量为KAFKA_MESSAGE_MAX_BYTES: 2000000；要关闭自动主题创建，设置KAFKA_AUTO_CREATE_TOPICS_ENABLE: 'false'

使用方法

启动集群

bash
docker-compose up -d

添加更多broker

bash
docker-compose scale kafka=3

销毁集群

bash
docker-compose stop

注意事项

默认的docker-compose.yml应视为起点。默认情况下，每个broker在重启时会获取新的端口号和broker id。根据使用场景，这可能不符合需求。如果需要使用特定端口和broker id，请相应修改docker-compose配置，例如使用https://github.com/wurstmeister/kafka-docker/blob/master/docker-compose-single-broker.yml%EF%BC%9A

bash
docker-compose -f docker-compose-single-broker.yml up

Broker IDs

如果未在docker-compose文件中指定broker id，它将根据docker-compose给容器的名称自动生成。这允许集群扩容和缩容。在这种情况下，建议使用docker-compose的--no-recreate选项，以确保容器不会被重新创建，从而保留其名称和id。

自动创建主题

如果希望kafka-docker在创建过程中自动在Kafka中创建主题，可以在docker-compose.yml中添加KAFKA_CREATE_TOPICS环境变量。

以下是docker-compose.yml中的示例片段：

yaml
environment:
  KAFKA_CREATE_TOPICS: "Topic1:1:3,Topic2:1:1"

其中，Topic1将有1个分区和3个副本，Topic2将有1个分区和1个副本。

教程

http://wurstmeister.github.io/kafka-docker/