antrea/kafka-consumer

Kafka Consumer (go-ipfix) 镜像文档

概述

该Docker镜像打包了基于https://github.com/vmware/go-ipfix%E5%BA%93%E5%AE%9E%E7%8E%B0%E7%9A%84%E7%8B%AC%E7%AB%8BKafka%E6%B6%88%E8%B4%B9%E8%80%85%EF%BC%8C%E6%8F%90%E4%BE%9B%E4%BE%BF%E6%8D%B7%E9%83%A8%E7%BD%B2%E6%96%B9%E5%BC%8F%EF%BC%8C%E4%B8%93%E9%97%A8%E7%94%A8%E4%BA%8E%E6%B5%8B%E8%AF%95Kafka%E7%94%9F%E4%BA%A7%E8%80%85%E5%8A%9F%E8%83%BD%E3%80%82

核心功能与特性

• 独立运行架构：无需额外依赖组件，可直接通过Docker容器独立启动
• 测试专用工具：专注于验证Kafka生产者的消息发送、格式兼容性等核心功能
• 基于go-ipfix库：采用VMware开源的go-ipfix库，具备高效的IPFIX协议处理能力

使用场景与适用范围

适用于开发、测试环境中对Kafka生产者进行功能验证，典型场景包括：

• 验证Kafka生产者的消息发送机制是否正常
• 检查生产者输出消息格式是否符合规范
• 测试不同负载条件下生产者的消息传输稳定性

使用方法与配置说明

基本部署命令

bash
docker run --name kafka-consumer -d [镜像名称]

注意：请将[镜像名称]替换为实际使用的Docker镜像标签

网络配置

确保容器能够访问目标Kafka集群，可通过--network参数指定网络环境，或通过环境变量配置Kafka broker地址：

bash
docker run --name kafka-consumer -e KAFKA_BROKERS=kafka:9092 -d [镜像名称]

详细配置参考

完整的配置选项、参数说明及高级使用方法，请查阅https://github.com/vmware/go-ipfix%E6%96%87%E6%A1%A3%E3%80%82

依赖说明

运行时需保证容器与目标Kafka集群网络连通，建议提前配置好Kafka broker地址及访问权限。