[
https://issues.apache.org/jira/browse/BEAM-7217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexey Romanenko closed BEAM-7217.
----------------------------------
Resolution: Duplicate
Fix Version/s: Not applicable
> 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
> Priority: Major
> Fix For: Not applicable
>
>
> 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)
