Re: [PR] add failed offset to Flink error messages [flink-statefun]

gfmio commented on code in PR #336: URL: https://github.com/apache/flink-statefun/pull/336#discussion_r1395492175 ## statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressDeserializer.java: ## @@ -45

Re: [PR] add failed offset to Flink error messages [flink-statefun]

kazimirov999 commented on code in PR #336: URL: https://github.com/apache/flink-statefun/pull/336#discussion_r1392929689 ## statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressDeserializer.java: ##

Re: [PR] add failed offset to Flink error messages [flink-statefun]

kazimirov999 commented on code in PR #336: URL: https://github.com/apache/flink-statefun/pull/336#discussion_r1392929689 ## statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressDeserializer.java: ##

Re: [PR] add failed offset to Flink error messages [flink-statefun]

kazimirov999 commented on code in PR #336: URL: https://github.com/apache/flink-statefun/pull/336#discussion_r1392929689 ## statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressDeserializer.java: ##