MINOR: close state store in CachingSessionStoreTest
close the sessions store in `After` to release rocksdb resources.
Author: Damian Guy
Reviewers: Guozhang Wang
Closes from dguy/minor-close-sesion-store
@@ -32,6 +32,7 @@ import org.apache.kafka.streams.state.KeyValueIterator;
import org.apache.kafka.streams.state.StateSerdes;
import org.apache.kafka.test.MockProcessorContext;
import org.apache.kafka.test.TestUtils;
+import org.junit.After;
import org.junit.Before;
import org.junit.Test;
@@ -69,6 +70,11 @@ public class CachingSessionStoreTest {
cachingStore.init(context, cachingStore);
}
+ @After
+ public void close() {
+ cachingStore.close();
+ }
+
@Test
public void shouldPutFetchFromCache() throws Exception {
cachingStore.put(new Windowed<>("a", new SessionWindow(0, 0)), 1L);
