ableegoldman commented on code in PR #14648:
URL: https://github.com/apache/kafka/pull/14648#discussion_r1399973308
##########
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilder.java:
##########
@@ -91,11 +91,13 @@ private KeyValueStore<Bytes, byte[]> maybeWrapLogging(final
KeyValueStore<Bytes,
}
private final static class InMemoryTimestampedKeyValueStoreMarker
+ extends WrappedStateStore<KeyValueStore<Bytes, byte[]>, Bytes, byte[]>
Review Comment:
ah, ok, that makes sense. In that case yeah, can you just make a quick pass
and update the calls in this? thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
