[ https://issues.apache.org/jira/browse/BEAM-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16739306#comment-16739306 ]
Ismaël Mejía commented on BEAM-4250: ------------------------------------ This looks like a duplicate of BEAM-6260 or does this refer to calling Java's IO from go? > Add Go SDK support for native Kafka IO on Flink > ----------------------------------------------- > > Key: BEAM-4250 > URL: https://issues.apache.org/jira/browse/BEAM-4250 > Project: Beam > Issue Type: Improvement > Components: sdk-go > Reporter: Henning Rohde > Priority: Major > Original Estimate: 48h > Remaining Estimate: 48h > > 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. -- This message was sent by Atlassian JIRA (v7.6.3#76005)