[GitHub] [kafka] rodesai commented on a change in pull request #8254: KIP-557: Add Emit On Change Support

2020-05-14 Thread GitBox
rodesai commented on a change in pull request #8254: URL: https://github.com/apache/kafka/pull/8254#discussion_r424941145 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java ## @@ -53,4 +56,48 @@ void

[GitHub] [kafka] rodesai commented on a change in pull request #8254: KIP-557: Add Emit On Change Support

2020-05-14 Thread GitBox
rodesai commented on a change in pull request #8254: URL: https://github.com/apache/kafka/pull/8254#discussion_r424941145 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java ## @@ -53,4 +56,48 @@ void