opensnowcat/opensnowcat-collector-kafka
opensnowcat
OpenSnowcat Kafka Collector是高可扩展的实时事件跟踪服务器，可从Snowplow和Segment SDK摄取事件并直接流到Kafka主题，支持自定义配置，适用于数据驱动的管道部署。
1 次收藏下载次数: 0状态：社区镜像维护者：opensnowcat仓库类型：镜像最近更新：4 个月前
让 AI 帮你使用轩辕镜像？ · 展开查看说明 · 点击收起说明
如果你使用 DeepSeek、元宝 AI、Copilot、ChatGPT 等 AI 工具，协助配置轩辕镜像、编写 docker pull 命令、修改 Docker Compose 镜像地址、配置镜像加速、排查镜像拉取失败、分析报错日志等问题，请先让 AI 阅读并遵守轩辕镜像的规则文档。
只需在 AI 对话中先发送下面这段话即可：
请先阅读并遵守：https://xuanyuan.cloud/agents.md
未读文档前不要生成 pull 命令或排错方案。查看 agents.md 用法指南与完整示范。国内用户首推 元宝 AI、DeepSeek 的深度思考模式，不推荐豆包 AI；Cursor 等编辑器可在对话 @ 该链接，或加入 User Rules。 若 AI 无法访问外链，可 打开说明文档 复制全文粘贴。文档会随站点更新，复制内容可能过期，建议定期检查。
OpenSnowcat Kafka Collector
OpenSnowcat Collector (Kafka) 是一款高可扩展的实时事件跟踪服务器，能够从Snowplow和Segment SDK摄取事件，并将其直接流传输至Kafka主题以进行后续处理。该Docker镜像便于在容器化环境中部署和配置收集器，支持自定义事件模式、payload格式，并包含日志、速率限制和安全相关选项，是利用Kafka作为传输层的数据驱动管道的理想选择。
核心功能
- 从Snowplow和Segment SDK实时摄取事件
- 直接将事件流传输至Kafka主题
- 支持自定义事件模式和payload格式
- 提供日志、速率限制和安全配置选项
- 高可扩展，适配容器化部署
使用场景
- 数据驱动的实时数据管道构建
- 事件数据的收集与传输
- 基于Kafka的流处理系统集成
配置说明
需挂载自定义配置文件config.hocon到容器内的/opensnowcat/config.hocon路径，以指定Kafka连接信息、事件处理规则等参数。
部署示例
docker run --rm \ -v $PWD/config.hocon:/opensnowcat/config.hocon \ -p 8080:8080 \ docker.xuanyuan.run/opensnowcat/opensnowcat-collector-kafka:latest --config /opensnowcat/config.hocon
文档与支持
- Opensnowcat.io
- Snowplow Discourse
- Slack社区：MeasureSlack、dbt、LocallyOptimistic
许可证
本软件采用Apache 2.0许可证。更多详情请访问https://github.com/opensnowcat/opensnowcat-collector
联系方式
如需更多信息，请联系***
镜像拉取方式
您可以使用以下命令拉取该镜像。请将 <标签> 替换为具体的标签版本。如需查看所有可用标签版本，请访问 标签列表页面。
轩辕镜像加速拉取命令点我查看更多 opensnowcat-collector-kafka 镜像标签
docker pull docker.xuanyuan.run/opensnowcat/opensnowcat-collector-kafka:<标签>
DockerHub 原生拉取命令
docker pull opensnowcat/opensnowcat-collector-kafka:<标签>
镜像拉取常见问题
功能
错误码
用户好评
来自真实用户的反馈，见证轩辕镜像的优质服务
oldzhang
运维工程师
Linux服务器
5
"Docker访问体验非常流畅，大镜像也能快速完成下载。"