confluentinc/cp-kafkacat

kafkacat Docker镜像

概述和主要用途

https://github.com/edenhill/kafkacat/ 是一个用于与Kafka broker交互的命令行工具，可实现消息的生产、消费及元数据查询功能。该Docker镜像专为Docker环境设计，通常与Docker部署的Kafka集群配合使用，使用时需注意容器网络与目标Kafka broker的连通性配置。

核心功能和特性

• 多场景交互：支持Kafka消息的生产（Produce）、消费（Consume）及元数据查询操作
• 命令行便捷性：通过简洁的命令参数实现与Kafka集群的快速交互
• 网络适配性：可通过Docker网络配置与同一Docker环境中的Kafka broker建立连接
• 文件与内联支持：支持从主机文件读取消息或通过脚本内联方式生产消息

使用场景和适用范围

• Kafka集群元数据管理：快速查看集群主题列表、分区分布等元数据信息
• 消息流测试：生产测试消息至Kafka主题或消费主题消息进行内容验证
• Docker环境集成：在Docker Compose或容器编排环境中作为临时工具容器使用

使用方法和配置说明

列出broker上的主题

若Kafka broker在Docker网络docker-compose_default中可通过kafka:29092访问，执行以下命令列出所有主题：

bash
docker run --tty \
           --network docker-compose_default \
           confluentinc/cp-kafkacat \
           kafkacat -b kafka:29092 \
                    -L

从主题消费消息

从主题foo消费消息并打印消息及元数据（假设Kafka broker地址为kafka:29092，网络为docker-compose_default）：

bash
docker run --tty \
           --network docker-compose_default \
           confluentinc/cp-kafkacat \
           kafkacat -b kafka:29092 -C -K: \
                    -f '\nKey (%K bytes): %k\t\nValue (%S bytes): %s\n\Partition: %p\tOffset: %o\n--\n' \
                    -t foo

从主机文件生产消息

将主机/tmp/my_msgs.txt文件中的内容作为消息生产至Kafka（需通过卷挂载文件，假设网络和broker地址同上）：

bash
docker run --network docker-compose_default \
           --volume /tmp/my_msgs.txt:/data/my_msgs.txt \
           confluentinc/cp-kafkacat \
           kafkacat -b kafka:29092 \
                    -t my_msgs \
                    -P -l /data/my_msgs.txt

从脚本内联生产消息

通过脚本内联方式生产消息（示例发送key:value格式消息至主题test，假设网络和broker地址同上）：

bash
docker run --interactive \
           --network docker-compose_default \
           confluentinc/cp-kafkacat \
            kafkacat -b kafka:29092 \
                    -t test \
                    -K: \
                    -P <<EOF
1:FOO
2:BAR
EOF

许可证

使用此镜像需遵守包含软件的许可条款。详情请参考Confluent Docker镜像文档参考。用于扩展和构建自定义Docker镜像的软件基于Apache 2.0许可证提供。