[
https://issues.apache.org/jira/browse/BEAM-13302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Beam JIRA Bot updated BEAM-13302:
---------------------------------
Labels: stale-assigned (was: )
> KafkaIO: Add support for outputting a PCollection
> -------------------------------------------------
>
> Key: BEAM-13302
> URL: https://issues.apache.org/jira/browse/BEAM-13302
> Project: Beam
> Issue Type: Improvement
> Components: io-java-kafka
> Reporter: Wei Hsia
> Assignee: Wei Fong Hsia
> Priority: P3
> Labels: stale-assigned
>
> Have KafkaIO’s WriteRecord PTransform output a PCollection, an extensible
> WriteResult type similar to that of BigQuery’s
> [WriteResult|https://beam.apache.org/releases/javadoc/2.6.0/org/apache/beam/sdk/io/gcp/bigquery/WriteResult.html]
> output.
> The original input, of [<ProducerRecord>
> type|https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/2.4.1/org/apache/kafka/clients/producer/ProducerRecord.html],
> will be returned as part of the WriteResult (or similar type), with a getter
> function.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
