Maik created FLINK-26097:
----------------------------
Summary: Kafka tombstone messages not working
Key: FLINK-26097
URL: https://issues.apache.org/jira/browse/FLINK-26097
Project: Flink
Issue Type: Bug
Components: Stateful Functions
Reporter: Maik
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)
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
