Alexey Romanenko created BEAM-7217:
--------------------------------------
Summary: ProducerRecordCoder is broken for old kafka-clients <=
0.10.2.*
Key: BEAM-7217
URL: https://issues.apache.org/jira/browse/BEAM-7217
Project: Beam
Issue Type: Bug
Components: io-java-kafka
Affects Versions: 2.10.0
Reporter: Alexey Romanenko
Assignee: Alexey Romanenko
>From user@:
https://lists.apache.org/thread.html/730b409dc453626b62993c2a5c995422b08e5cf23f68a9a86982bc1f@%3Cuser.beam.apache.org%3E
"In Beam 2.9.0, this check was made:
https://github.com/apache/beam/blob/2ba00576e3a708bb961a3c64a2241d9ab32ab5b3/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaRecordCoder.java#L132
However this logic was removed in 2.10+ in the newer ProducerRecordCoder class:
https://github.com/apache/beam/blob/release-2.10.0/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ProducerRecordCoder.java#L137
We are attempting to use Beam 2.10 with kafka 0.10.2.1; this is advertised as
supported here:
https://beam.apache.org/releases/javadoc/2.10.0/org/apache/beam/sdk/io/kafka/KafkaIO.html
However we are experiencing issues with the `headers` method call mentioned
above. Is there a way around this?"
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
