From 9a1f20ebba5d98a08cbada7ef42c4e15161d78d5 Mon Sep 17 00:00:00 2001 From: Lucas Bradstreet Date: Mon, 6 May 2019 19:01:40 -0700 Subject: [PATCH] MINOR: MetricsIntegrationTest should set StreamsConfig.STATE_DIR_CONFIG --- .../apache/kafka/streams/integration/MetricsIntegrationTest.java | 1 + 1 file changed, 1 insertion(+) diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/MetricsIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/MetricsIntegrationTest.java index 3ce31cb328955..3f6c80691f0e6 100644 --- a/streams/src/test/java/org/apache/kafka/streams/integration/MetricsIntegrationTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/integration/MetricsIntegrationTest.java @@ -179,6 +179,7 @@ public void before() throws InterruptedException { streamsConfiguration.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass()); streamsConfiguration.put(StreamsConfig.METRICS_RECORDING_LEVEL_CONFIG, Sensor.RecordingLevel.DEBUG.name); streamsConfiguration.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 10 * 1024 * 1024L); + streamsConfiguration.put(StreamsConfig.STATE_DIR_CONFIG, TestUtils.tempDirectory().getPath()); } @After