You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Alexey Romanenko (Jira)" <ji...@apache.org> on 2022/01/28 18:02:00 UTC

[jira] [Assigned] (BEAM-13302) KafkaIO: Add support for outputting a PCollection

     [ https://issues.apache.org/jira/browse/BEAM-13302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Alexey Romanenko reassigned BEAM-13302:
---------------------------------------

    Assignee: Wei Fong Hsia

> 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
>
> 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)