apache / apache/beam

Add API for setting Kafka type serializers and deserializers

Open
#21,000 0 comments 0 reactions 0 assignees View on GitHub
go new feature P3
Dominant language
Java
Stars
8.7k
Forks
4.7k
Avg merge
1d 20h
Merged PRs (30d)
196

Description

This requires figuring out how exactly the elements returned by the cross-language transform change based on the serializer/deserializer used, as well as configuring the Go SDK side to be as usable as possible, including correctly setting coders and documenting what Go types will be used.

Imported from Jira [BEAM-12492](https://issues.apache.org/jira/browse/BEAM-12492). Original Jira may contain additional context.
Reported by: danoliveira.

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.