kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-3669; Add secondary constructor for KafkaConfig with a default value for doLog
Date Fri, 06 May 2016 20:47:05 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 198503312 -> 58f9d7cf8


KAFKA-3669; Add secondary constructor for KafkaConfig with a default value for doLog

…value for doLog

Author: Mark Grover <mark@apache.org>

Reviewers: Grant Henke <granthenke@gmail.com>, Ismael Juma <ismael@juma.me.uk>

Closes #1334 from markgrover/kafka-3669-trunk


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

Branch: refs/heads/trunk
Commit: 58f9d7cf8a68824a8fc451cf7ff5fcfb696fa863
Parents: 1985033
Author: Mark Grover <mark@apache.org>
Authored: Fri May 6 21:47:00 2016 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Fri May 6 21:47:00 2016 +0100

----------------------------------------------------------------------
 core/src/main/scala/kafka/server/KafkaConfig.scala | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/58f9d7cf/core/src/main/scala/kafka/server/KafkaConfig.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala b/core/src/main/scala/kafka/server/KafkaConfig.scala
index c5da55d..596cc58 100755
--- a/core/src/main/scala/kafka/server/KafkaConfig.scala
+++ b/core/src/main/scala/kafka/server/KafkaConfig.scala
@@ -758,6 +758,8 @@ object KafkaConfig {
 
 class KafkaConfig(val props: java.util.Map[_, _], doLog: Boolean) extends AbstractConfig(KafkaConfig.configDef,
props, doLog) {
 
+  def this(props: java.util.Map[_, _]) = this(props, true)
+
   /** ********* Zookeeper Configuration ***********/
   val zkConnect: String = getString(KafkaConfig.ZkConnectProp)
   val zkSessionTimeoutMs: Int = getInt(KafkaConfig.ZkSessionTimeoutMsProp)


Mime
View raw message