eduwercamacaro commented on code in PR #21578:
URL: https://github.com/apache/kafka/pull/21578#discussion_r2896862016
##########
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBStoreTest.java:
##########
@@ -356,6 +356,7 @@ public
RocksDBConfigSetterWithUserProvidedNewPlainTableFormatConfig() {}
public void setConfig(final String storeName, final Options options,
final Map<String, Object> configs) {
options.setTableFormatConfig(new PlainTableConfig());
+ options.useFixedLengthPrefixExtractor(1);
Review Comment:
I added this because this test uses PlainTable format, and this config
requires using a prefix extractor when flushing the memtables to disk. But now,
I already removed the code to flush the memtable during initialization, so I
reverted this change.
--
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]
