conitasgmbh/kafka-cli

kafka-cli Docker镜像文档

镜像概述和主要用途

kafka-cli是一个基于Alpine Linux发行版的Docker镜像，旨在提供体积小巧的Kafka命令行工具环境。该镜像包含完整的Kafka CLI工具集，可方便用户与Kafka集群进行交互，执行消息生产、消费、主题管理等操作。灵感来源于GitHub项目：https://github.com/taion809/kafka-cli%E3%80%82

核心功能和特性

• 轻量级基础：基于Alpine Linux构建，镜像体积小，资源占用低
• 完整工具集：包含Kafka核心命令行工具，如kafka-console-consumer.sh、kafka-console-producer.sh、kafka-topics.sh等
• 多环境支持：兼容Docker Compose本地开发环境和Kubernetes集群环境
• 快速部署：提供简单的部署脚本，可快速启动和使用

使用场景和适用范围

• 本地Kafka开发与测试环境，快速验证消息生产与消费流程
• Kubernetes集群中与Kafka集群的临时或持续交互操作
• 主题创建、配置修改等Kafka集群管理任务
• 自动化脚本或CI/CD流程中的Kafka操作工具

使用方法和配置说明

Docker Compose部署

构建镜像

bash
docker-compose build

启动演示环境

bash
docker-compose up -d

运行消费者

bash
docker-compose exec kafka-cli kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic test --from-beginning

运行生产者

bash
docker-compose exec kafka-cli kafka-console-producer.sh --broker-list kafka:9092 --topic test

在生产者控制台输入消息，消费者将实时接收并显示这些消息。

Kubernetes部署

前提：Kafka集群已在Kubernetes中运行

部署kafka-cli Pod

在指定命名空间（如dev）中部署：

bash
kubectl -n dev apply -f k8s.yml

创建主题（如不存在）

bash
kubectl -n dev exec -it kafka-cli -- kafka-topics.sh --create --bootstrap-server kafka:9092 --topic test --replication-factor 1 --partitions 1

运行消费者

bash
kubectl -n dev exec -it kafka-cli -- kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic test --from-beginning

运行生产者

bash
kubectl -n dev exec -it kafka-cli -- kafka-console-producer.sh --broker-list kafka:9092 --topic test