mjsax commented on code in PR #21455:
URL: https://github.com/apache/kafka/pull/21455#discussion_r2830528224
##########
streams/src/main/java/org/apache/kafka/streams/state/Stores.java:
##########
@@ -113,7 +114,26 @@ public static KeyValueBytesStoreSupplier
persistentKeyValueStore(final String na
*/
public static KeyValueBytesStoreSupplier
persistentTimestampedKeyValueStore(final String name) {
Objects.requireNonNull(name, "name cannot be null");
- return new RocksDBKeyValueBytesStoreSupplier(name, true);
+ return new RocksDBKeyValueBytesStoreSupplier(name, true, false);
+ }
+
+ /**
+ * Create a persistent {@link KeyValueBytesStoreSupplier}.
+ * <p>
+ * This store supplier can be passed into a
+ * {@link #timestampedKeyValueStoreBuilder(KeyValueBytesStoreSupplier,
Serde, Serde)}.
+ * If you want to create a {@link KeyValueStore} or a {@link
VersionedKeyValueStore}
+ * you should use {@link #KeyValueStore(String)} or
Review Comment:
Build is complaining about this one `{@link #KeyValueStore(String)} `
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
