[GitHub] [kafka] richard-axual commented on a change in pull request #11535: KAFKA-13476: Increase resilience timestamp decoding Kafka Streams

richard-axual commented on a change in pull request #11535: URL: https://github.com/apache/kafka/pull/11535#discussion_r777961628 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java ## @@ -1097,15 +1097,20 @@ long decodeTimestamp(fi

[GitHub] [kafka] richard-axual commented on a change in pull request #11535: KAFKA-13476: Increase resilience timestamp decoding Kafka Streams

richard-axual commented on a change in pull request #11535: URL: https://github.com/apache/kafka/pull/11535#discussion_r773828829 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java ## @@ -1097,15 +1097,20 @@ long decodeTimestamp(fi

[GitHub] [kafka] richard-axual commented on a change in pull request #11535: KAFKA-13476: Increase resilience timestamp decoding Kafka Streams

richard-axual commented on a change in pull request #11535: URL: https://github.com/apache/kafka/pull/11535#discussion_r771190189 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java ## @@ -1097,15 +1097,20 @@ long decodeTimestamp(fi