[FLINK-26097] Kafka tombstone messages not working

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Stateful Functions
• Assignee: Igal Shilman
• Reporter: Maik
• Created: 12/Feb/22 14:36
• Updated: 16/Feb/22 15:58

Description

java.lang.NullPointerException
at com.google.protobuf.ByteString$LiteralByteString.<init>(ByteString.java:1282)
at com.google.protobuf.ByteString.wrap(ByteString.java:382)
at com.google.protobuf.MoreByteStrings.wrap(MoreByteStrings.java:25)
at org.apache.flink.statefun.flink.io.kafka.binders.ingress.v1.RoutableKafkaIngressDeserializer.deserialize(RoutableKafkaIngressDeserializer.java:59)
at org.apache.flink.statefun.flink.io.kafka.binders.ingress.v1.RoutableKafkaIngressDeserializer.deserialize(RoutableKafkaIngressDeserializer.java:29)
at org.apache.flink.statefun.flink.io.kafka.KafkaDeserializationSchemaDelegate.deserialize(KafkaDeserializationSchemaDelegate.java:46)
at org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema.deserialize(KafkaDeserializationSchema.java:79)
at org.apache.flink.streaming.connectors.kafka.internals.KafkaFetcher.partitionConsumerRecordsHandler(KafkaFetcher.java:179)
at org.apache.flink.streaming.connectors.kafka.internals.KafkaFetcher.runFetchLoop(KafkaFetcher.java:142)
at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.run(FlinkKafkaConsumerBase.java:826)
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67)
at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323)