You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jj...@apache.org on 2015/03/04 01:04:15 UTC
kafka git commit: KAFKA-2001;
Trivial commit to prevent OffsetCommitTest from hanging
Repository: kafka
Updated Branches:
refs/heads/trunk 57d38f672 -> 61f02fa54
KAFKA-2001; Trivial commit to prevent OffsetCommitTest from hanging
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/61f02fa5
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/61f02fa5
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/61f02fa5
Branch: refs/heads/trunk
Commit: 61f02fa542380e70c837fbc52deac74daec62505
Parents: 57d38f6
Author: Joel Koshy <jj...@gmail.com>
Authored: Tue Mar 3 16:03:24 2015 -0800
Committer: Joel Koshy <jj...@gmail.com>
Committed: Tue Mar 3 16:03:24 2015 -0800
----------------------------------------------------------------------
core/src/main/scala/kafka/server/OffsetManager.scala | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/61f02fa5/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 d2d5962..8d41520 100644
--- a/core/src/main/scala/kafka/server/OffsetManager.scala
+++ b/core/src/main/scala/kafka/server/OffsetManager.scala
@@ -170,7 +170,6 @@ 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, "none")
props
}