Wei Hsia created BEAM-13302:
-------------------------------
Summary: 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
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)
