From 1af052a998cc45420ff182ce925c00a073a512e5 Mon Sep 17 00:00:00 2001 From: Damian Guy Date: Thu, 9 Feb 2017 14:35:38 +0000 Subject: [PATCH] lower rocks db defaults --- .../apache/kafka/streams/state/internals/RocksDBStore.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java index 108c77252d3e3..13d96d3c9a178 100644 --- a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java +++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java @@ -70,8 +70,8 @@ public class RocksDBStore implements KeyValueStore { // TODO: these values should be configurable private static final CompressionType COMPRESSION_TYPE = CompressionType.NO_COMPRESSION; private static final CompactionStyle COMPACTION_STYLE = CompactionStyle.UNIVERSAL; - private static final long WRITE_BUFFER_SIZE = 32 * 1024 * 1024L; - private static final long BLOCK_CACHE_SIZE = 100 * 1024 * 1024L; + private static final long WRITE_BUFFER_SIZE = 16 * 1024 * 1024L; + private static final long BLOCK_CACHE_SIZE = 50 * 1024 * 1024L; private static final long BLOCK_SIZE = 4096L; private static final int TTL_SECONDS = TTL_NOT_USED; private static final int MAX_WRITE_BUFFERS = 3;