Details
-
Bug
-
Status: Resolved
-
P3
-
Resolution: Fixed
-
2.10.0, 2.11.0, 2.12.0
-
None
Description
In beam 2.9.0, KafkaRecordCoder was used for both producer/consumer records in KafkaIO, in version 2.10.0, ProducerRecordCoder was introduced but it appears that in the following code checks are not made to ensure kafka client compatibility:
Specifically the method call to `headers` will fail for kafka clients < 0.11. Elsewhere in this class there are checks on ConsumerSpEL and it is proposed that they should be reused in the line referenced.
Attachments
Issue Links
- links to