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:18 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.0 aabf82514 -> 7ad2d3df8


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

(cherry picked from commit 58f9d7cf8a68824a8fc451cf7ff5fcfb696fa863)
Signed-off-by: Ismael Juma <ismael@juma.me.uk>


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

Branch: refs/heads/0.10.0
Commit: 7ad2d3df8eb0b3c23baff04efc30a0b4c6752b19
Parents: aabf825
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:12 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/7ad2d3df/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