[
https://issues.apache.org/jira/browse/FLINK-26097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493318#comment-17493318
]
Igal Shilman commented on FLINK-26097:
--------------------------------------
Thanks for reporting this [~Kazmierski]. Indeed it seems like the default kafka
ingress does not support tombstone messages.
> 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
> Priority: Major
>
> 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)
