kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jjko...@apache.org
Subject kafka git commit: KAFKA-2001; Trivial commit to fix OffsetCommitTest
Date Wed, 04 Mar 2015 00:14:23 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 61f02fa54 -> 4c9ad9b8a


KAFKA-2001; Trivial commit to fix OffsetCommitTest


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

Branch: refs/heads/trunk
Commit: 4c9ad9b8a23e5487fc17579c46472c3693114d8b
Parents: 61f02fa
Author: Joel Koshy <jjkoshy@gmail.com>
Authored: Tue Mar 3 16:14:03 2015 -0800
Committer: Joel Koshy <jjkoshy@gmail.com>
Committed: Tue Mar 3 16:14:03 2015 -0800

----------------------------------------------------------------------
 core/src/main/scala/kafka/server/OffsetManager.scala | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/4c9ad9b8/core/src/main/scala/kafka/server/OffsetManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/OffsetManager.scala b/core/src/main/scala/kafka/server/OffsetManager.scala
index 8d41520..d05e14d 100644
--- a/core/src/main/scala/kafka/server/OffsetManager.scala
+++ b/core/src/main/scala/kafka/server/OffsetManager.scala
@@ -170,6 +170,7 @@ class OffsetManager(val config: OffsetManagerConfig,
     val props = new Properties
     props.put(LogConfig.SegmentBytesProp, config.offsetsTopicSegmentBytes.toString)
     props.put(LogConfig.CleanupPolicyProp, "compact")
+    props.put(LogConfig.CompressionTypeProp, "uncompressed")
     props
   }
 


Mime
View raw message