kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: Change rocksdb logging to error level
Date Wed, 01 Feb 2017 20:36:03 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk cea461353 -> 3d9f34dd8


MINOR: Change rocksdb logging to error level

According to the java-doc: https://github.com/facebook/rocksdb/blob/master/java/src/main/java/org/rocksdb/Logger.java#L31
the rocksdb logging level should be set Error or Fatal for production usage.

Author: Damian Guy <damian.guy@gmail.com>

Reviewers: Matthias J. Sax, Guozhang Wang

Closes #2477 from dguy/rocks-db-logging


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/3d9f34dd
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/3d9f34dd
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/3d9f34dd

Branch: refs/heads/trunk
Commit: 3d9f34dd84a1c802b18874ba365c23713bfb189a
Parents: cea4613
Author: Damian Guy <damian.guy@gmail.com>
Authored: Wed Feb 1 12:35:59 2017 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Wed Feb 1 12:35:59 2017 -0800

----------------------------------------------------------------------
 .../org/apache/kafka/streams/state/internals/RocksDBStore.java     | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/3d9f34dd/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java
----------------------------------------------------------------------
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 5c83ddf..280d5c4 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
@@ -35,6 +35,7 @@ import org.rocksdb.BlockBasedTableConfig;
 import org.rocksdb.CompactionStyle;
 import org.rocksdb.CompressionType;
 import org.rocksdb.FlushOptions;
+import org.rocksdb.InfoLogLevel;
 import org.rocksdb.Options;
 import org.rocksdb.RocksDB;
 import org.rocksdb.RocksDBException;
@@ -120,6 +121,7 @@ public class RocksDBStore<K, V> implements KeyValueStore<K, V>
{
         options.setMaxWriteBufferNumber(MAX_WRITE_BUFFERS);
         options.setCreateIfMissing(true);
         options.setErrorIfExists(false);
+        options.setInfoLogLevel(InfoLogLevel.ERROR_LEVEL);
 
         wOptions = new WriteOptions();
         wOptions.setDisableWAL(true);


Mime
View raw message