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 <[email protected]> Reviewers: Ismael Juma <[email protected]> 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 <[email protected]> Authored: Thu May 11 13:59:48 2017 +0100 Committer: Ismael Juma <[email protected]> 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)
