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

Posted to issues@beam.apache.org by "Rion Williams (Jira)" <ji...@apache.org> on 2021/02/12 01:57:00 UTC

[jira] [Created] (BEAM-11806) KafkaIO - Partition Recognition in WriteRecords

Rion Williams created BEAM-11806:
------------------------------------

             Summary: KafkaIO - Partition Recognition in WriteRecords
                 Key: BEAM-11806
                 URL: https://issues.apache.org/jira/browse/BEAM-11806
             Project: Beam
          Issue Type: Improvement
          Components: io-java-kafka, io-py-kafka
            Reporter: Rion Williams
            Assignee: Rion Williams


At present, the `WriteRecords` support for the KafkaIO does not recognize the `partition` property defined on `ProducerRecord` instances consumed by the transform. This ticket would added support so that any explicit partitioning that was defined would be acknowledged accordingly while still respecting the default behavior if it was not explicitly included.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)