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)
