Add Go SDK support for native Kafka IO on Flink
Open
go
improvement
P3
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 196
Description
If and when the Flink runner supports native Kafka IO, we should be able to generate that intrinsic transform with beam.External similarly to PubSub IO on Dataflow.
Imported from Jira [BEAM-4250](https://issues.apache.org/jira/browse/BEAM-4250). Original Jira may contain additional context.
Reported by: herohde.
Contributor guide
Assessment
This issue has not been assessed yet.