Publish Message Queues - Kafka 4.0 Queues (Shared Groups)
维护者通常 1 天内回复
还没有人认领这个 Issue。
评估
- 难度
- 4/5
- 预计耗时
- 3-5 天
- 新手友好度
- 32/100
- Issue 类型
- 功能
- 描述清晰度
- 基本清楚
- 活跃度
- 停滞
- 技术栈
- go, kafka
调研方向
Start by reading the existing RabbitMQ and AWS SQS queue integrations to understand how queue sources feed events into publishing. Then compare the proposed event fields and Kafka key, topic, payload, and header mapping with the Kafka queues behavior described in the linked reference. Done means Kafka queues can serve as an event source alongside RabbitMQ and SQS, with the proposed event data mapped to Kafka messages.
由索引模型根据 Issue 内容生成。
描述
Is your feature request related to a problem? Please describe.
Would be nice to get next to the existing queues also support for the new Kafka Queue system as a source for events to be published. Allowing reuse of an existing Kafka deployment base.
Describe the solution you'd like
Allow next to RabbitMQ & AWS SQS also Kafka Queues to be a source of events to be published. See https://www.confluent.io/de-de/blog/queues-on-kafka/
Considering the following event structure:
{
"id": "123", // Optional but recommended. If left empty, ID will be generated by hashing the topic, data and timestamp
"tenant_id": "12345",
"destination_id": "12345", // Optional. Used to force delivery to a specific destination
"topic": "something.created", // Optional. Assumed to match ANY topic if left empty.
"eligible_for_retry": false, // Optional, default to "false". Control if an event should be retried.
"time": "2024-06-01 08:23:36.082374Z", // ISO Timestamp of the event
"metadata": {
// Arbitrary key-value mapping for event
"key": "value" // String, number or boolean
},
"data": {
// Freeform JSON data
"hello": "world"
}
}
id --> Kafka Message Key
time --> time of the message
topic --> Kafka Topic name
data --> Kafka Message payload (json encoded)
Further data could be added as a Headers
Additional context
Add any other context or screenshots about the feature request here.
- 主要语言
- Go
- 星标
- 1.1k
- 派生
- 70
- 平均合并
- 1 天 18 小时
- 30 天内合并 PR
- 56
环境准备
这个项目没有提供开发容器、Dockerfile 或贡献指南，环境需要你自己搭建：先看它的 README，通用步骤见我们的新手贡献指南。
从这里开始
- 先读完整个 Issue，再读项目的贡献指南。
- 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
- Fork 仓库，在一个分支上完成修改。
- 提交 Pull Request，并在描述里引用这个 Issue 编号。
hookdeck/outpost 的其他 Issue
-
难度 2/5 1-3 小时 新手友好度 68/100
维护者通常 1 天内回复
-
难度 2/5 1-3 小时 新手友好度 76/100
维护者通常 1 天内回复
-
enhancement
难度 4/5 3-5 天 新手友好度 48/100
hookdeck/outpost#1117 · 1 条评论 · 1 个 reaction ·
维护者通常 1 天内回复
-
难度 4/5 3-5 天 新手友好度 35/100
维护者通常 1 天内回复
-
难度 4/5 3-5 天 新手友好度 45/100
维护者通常 1 天内回复
相似的 Issue
-
难度 1/5 1 小时以内 新手友好度 85/100
维护者通常 1 天内回复
-
kind/bug
难度 1/5 1-3 小时 新手友好度 85/100
kubernetes-sigs/vsphere-csi-driver#4351 ·
维护者通常 1 天内回复
-
component/gpu-kubelet-plugin component/helm needs-triage
难度 2/5 1-3 小时 新手友好度 62/100
kubernetes-sigs/dra-driver-nvidia-gpu#1559 ·
维护者通常 1 天内回复
-
workflow: redundant goroutine in scheduleRetry可能已有人在做 @moodbased 今天认领。 未关闭
难度 2/5 1-3 小时 新手友好度 70/100
维护者通常 2 天内回复
-
难度 2/5 1-3 小时 新手友好度 68/100
JuliusBrussee/caveman#1266 · 2 条评论 ·
维护者通常 1 天内回复