solsson/kafkacat-curl

solsson/kafkacat-curl镜像说明

镜像概述

solsson/kafkacat-curl是基于kafkacat工具的变体镜像，额外集成了curl网络请求工具，旨在提供轻量、便捷的容器环境，同时支持Kafka集群交互与HTTP/HTTPS网络操作，适配Kubernetes-Kafka相关场景的使用需求。

核心功能

1. Kafka交互能力：支持Kafka消息的生产、消费、元数据查询等基础操作（继承kafkacat核心功能）；
2. 网络请求支持：通过集成curl工具，可实现HTTP/HTTPS请求、API调用、服务健康检查等网络操作；
3. 轻量适配：镜像体积小，适合在容器化环境（如Kubernetes）中快速部署使用。

使用场景

1. Kubernetes集群内Kafka消息流的调试与验证；
2. 结合curl进行Kafka相关服务的API状态检查；
3. 快速验证Kafka集群与外部服务的网络连通性；
4. 适配Yolean/kubernetes-kafka项目的特定需求（如PR#60场景）。

配置说明

• kafkacat配置：可通过命令行参数传递broker地址、topic名称等（如kafkacat -b <broker地址> -t <topic名称>）；
• curl配置：遵循curl标准命令格式（如curl <URL> -X GET）。

部署示例

Docker Run示例

1. 消费Kafka消息：

bash
docker run --rm solsson/kafkacat-curl kafkacat -b kafka-broker:9092 -t test-topic -C

2. 执行网络请求：

bash
docker run --rm solsson/kafkacat-curl curl http://service-api:8080/health

Docker Compose示例（片段）

yaml
services:
  kafkacat-curl:
    image: solsson/kafkacat-curl
    command: ["kafkacat", "-b", "kafka:9092", "-t", "demo-topic", "-P"]
    volumes:
      - ./messages.txt:/messages.txt
    stdin_open: true
    tty: true