edoardocomar commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1073801293
Hi @dongjinleekr would you consider this patch to fix the compilation error
```
diff --git
streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java
streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java
index 2bfbe4e36b..3cbb5c6369 100644
--- streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java
+++ streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java
@@ -1039,7 +1039,9 @@ public class StreamsConfigTest {
@Test
public void shouldSpecifyRocksdbWhenNotExplicitlyAddedToConfigs() {
final String expectedDefaultStoreType = StreamsConfig.ROCKS_DB;
- final String actualDefaultStoreType =
streamsConfig.getString(DEFAULT_DSL_STORE_CONFIG);
+ props.put(DEFAULT_DSL_STORE_CONFIG, expectedDefaultStoreType);
+ final StreamsConfig config = new StreamsConfig(props);
+ final String actualDefaultStoreType =
config.getString(DEFAULT_DSL_STORE_CONFIG);
assertEquals("default.dsl.store should be \"rocksDB\"",
expectedDefaultStoreType, actualDefaultStoreType);
}
```
--
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]
