kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: HOTFIX: change compression codec in TransactionStateManager to UncompressedCodec
Date Thu, 11 May 2017 12:59:57 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 3085d4f43 -> 24a4e6146


HOTFIX: change compression codec in TransactionStateManager to UncompressedCodec

Change the compression code used for the transaction log to UncompressedCoded as it fails
during creation when the codec is set to NoCompressionCodec.

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

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #3022 from dguy/hotfix-tsm


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

Branch: refs/heads/trunk
Commit: 24a4e6146a83c3ce188f6ee2f56d763a58b88b8b
Parents: 3085d4f
Author: Damian Guy <damian.guy@gmail.com>
Authored: Thu May 11 13:59:48 2017 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Thu May 11 13:59:48 2017 +0100

----------------------------------------------------------------------
 .../kafka/coordinator/transaction/TransactionStateManager.scala  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/24a4e614/core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala
b/core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala
index 7930cd0..e23324f 100644
--- a/core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala
+++ b/core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala
@@ -24,7 +24,7 @@ import java.util.concurrent.locks.ReentrantLock
 
 import kafka.common.{KafkaException, Topic}
 import kafka.log.LogConfig
-import kafka.message.NoCompressionCodec
+import kafka.message.UncompressedCodec
 import kafka.server.ReplicaManager
 import kafka.utils.CoreUtils.inLock
 import kafka.utils.{Logging, Pool, Scheduler, ZkUtils}
@@ -117,7 +117,7 @@ class TransactionStateManager(brokerId: Int,
 
     // enforce disabled unclean leader election, no compression types, and compact cleanup
policy
     props.put(LogConfig.UncleanLeaderElectionEnableProp, "false")
-    props.put(LogConfig.CompressionTypeProp, NoCompressionCodec)
+    props.put(LogConfig.CompressionTypeProp, UncompressedCodec.name)
     props.put(LogConfig.CleanupPolicyProp, LogConfig.Compact)
 
     props.put(LogConfig.MinInSyncReplicasProp, config.transactionLogMinInsyncReplicas.toString)


Mime
View raw message