knative-extensions / knative-extensions/func-go
Kafka middleware: CloudEvent message format detection
- Dominant language
- Go
- Stars
- 7
- Forks
- 12
- PR merge metrics
- No merged PRs in 30d
Description
Auto-detect CloudEvent-formatted Kafka messages (via `ce-*` headers or content inspection) and optionally deliver them as structured CloudEvent objects. This enables interoperability with Knative Eventing sources that produce CE-formatted Kafka messages.
Non-CE messages would still be delivered as raw bytes.
Related: #181 (pluggable serialization — both extend the message format, could share a deserialization framework).
Contributor guide
Research direction
Start at the Kafka middleware's message handling and existing deserialization entry points; no specific files or tests are identified in the issue. Review related issue #181 for the shared framework discussion, then define completion as detecting CE headers or content, optionally delivering structured CloudEvent objects, and preserving raw bytes for non-CE messages.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- go, kafka
- Domain
- distributed-systems, stream-processing
- Issue type
- Feature
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Quiet
- Clarity
- Mostly clear
- Newbie friendliness
- 48/100