Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Duplicate
-
2.10.0
-
None
Description
"In Beam 2.9.0, this check was made:
However this logic was removed in 2.10+ in the newer ProducerRecordCoder class:
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?"