knative-extensions / knative-extensions/func-go

Kafka middleware: pluggable serialization (Avro, Protobuf, Schema Registry)

Open
#181 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Go
Stars
7
Forks
12
PR merge metrics
No merged PRs in 30d

Description

Add configurable message deserialization so the handler can receive typed objects instead of raw bytes:

- JSON to typed struct
- Avro with Confluent Schema Registry
- Protobuf with schema registry
- Custom deserializers

Related: #180 (CloudEvent detection — both extend the message format).

Contributor guide

Open the contributing guide

Research direction

Start by locating the Kafka middleware and the handler path that currently exposes raw bytes, then review related issue #180 for interaction with message formats. Done means the handler can receive typed objects through JSON, Avro with Confluent Schema Registry, Protobuf with schema registry, and custom deserializers.

Written by the indexing model from the issue text.

Assessment

Tech stack
go, kafka
Domain
backend, distributed-systems
Issue type
Feature
Difficulty
5/5
Estimated time
Over a week
Activity status
Quiet
Clarity
Mostly clear
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.