maestrano/kafka

Maestrano Kafka

Apache Kafka的Docker镜像，用于简化Kafka服务的部署和运行。

镜像概述和主要用途

Maestrano Kafka镜像提供了Apache Kafka的容器化部署方案，支持主从容器模式，通过环境变量即可配置关键参数，适用于快速搭建Kafka服务环境。

核心功能和特性

• 支持主容器和从容器部署模式
• 通过环境变量配置ZooKeeper和Kafka参数
• 暴露Kafka（9092）和ZooKeeper（2181）默认端口
• 包含Kafka和ZooKeeper的基础操作工具

使用场景和适用范围

适用于开发、测试环境中快速搭建单节点或多节点Kafka服务，也可作为Kafka学习和演示环境的基础镜像。

构建和运行镜像

构建镜像

bash
docker build -t docker-kafka ./0.10

运行主容器

bash
docker run -p 2181:2181 -p 9092:9092 --env ZK_CHROOT=kafka --env SELF_HOST=localhost --env SELF_PORT=9092 docker-kafka

环境变量说明：

• ZK_CHROOT：ZooKeeper中Kafka的根路径，默认为"kafka"
• SELF_HOST：Kafka broker的主机地址，需设置为可访问的主机名或IP
• SELF_PORT：Kafka broker的端口，默认为9092

运行从容器

bash
docker run -p 2181:2181 -p 9092:9092 --env ZK_MASTER=ip:port/kafka --env SELF_HOST=localhost --env SELF_PORT=9092 docker-kafka

环境变量说明：

• ZK_MASTER：主容器的ZooKeeper地址，格式为"ip:port/chroot"
• SELF_HOST和SELF_PORT：从容器的Kafka broker地址和端口

基本使用

设置环境变量

bash
export KAFKA=localhost:9092  # Kafka broker地址
export ZOOKEEPER=localhost:2181/kafka  # ZooKeeper地址（包含Kafka根路径）

列出Kafka Brokers

bash
zookeeper-shell $ZOOKEEPER <<< "ls /brokers/ids"

操作主题

• 创建主题：

  bash
  kafka-topics --create --zookeeper $ZOOKEEPER -replication-factor 1 --partitions 1 --topic test
  

• 列出所有主题：

  bash
  kafka-topics --list --zookeeper $ZOOKEEPER
  

• 描述主题：

  bash
  kafka-topics --describe --zookeeper $ZOOKEEPER --topic test
  

生产和消费事件

• 生产事件：

  bash
  kafka-console-producer --broker-list $KAFKA --topic test
  

• 消费事件（从开始位置）：

  bash
  kafka-console-consumer --bootstrap-server $KAFKA --topic test --from-beginning