[
https://issues.apache.org/jira/browse/BEAM-10529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520624#comment-17520624
] John Casey commented on BEAM-10529: ----------------------------------- Hi Matthias, that looks odd. Do you have the root exception that caused the illegal argument exception to be thrown? > Kafka XLang fails for ?empty? key/values > ---------------------------------------- > > Key: BEAM-10529 > URL: https://issues.apache.org/jira/browse/BEAM-10529 > Project: Beam > Issue Type: Bug > Components: cross-language, io-java-kafka > Reporter: Luke Cwik > Assignee: John Casey > Priority: P1 > Fix For: 2.38.0 > > Time Spent: 25h 20m > Remaining Estimate: 0h > > It looks like the Javadoc for ByteArrayDeserializer and StringDeserializer > can return null[1, 2] and we aren't using > NullableCoder.of(ByteArrayCoder.of()) in the expansion[3]. Note that KafkaIO > does this correctly in its regular coder inference logic[4]. > 1: > [https://kafka.apache.org/21/javadoc/org/apache/kafka/common/serialization/ByteArrayDeserializer.html#deserialize-java.lang.String-byte:A-|https://kafka.apache.org/21/javadoc/org/apache/kafka/common/serialization/ByteArrayDeserializer.html#deserialize-java.lang.String-byte:A-2:] > [2:|https://kafka.apache.org/21/javadoc/org/apache/kafka/common/serialization/ByteArrayDeserializer.html#deserialize-java.lang.String-byte:A-2:] > > [https://kafka.apache.org/21/javadoc/org/apache/kafka/common/serialization/StringDeserializer.html#deserialize-java.lang.String-byte:A-] > 3: > [https://github.com/apache/beam/blob/af2d6b0379d64b522ecb769d88e9e7e7b8900208/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java#L478] > 4: > [https://github.com/apache/beam/blob/af2d6b0379d64b522ecb769d88e9e7e7b8900208/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/LocalDeserializerProvider.java#L85] -- This message was sent by Atlassian Jira (v8.20.1#820001)
