kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: MINOR: Add secondary constructor that takes only `props` in `KafkaConfig`
Date Mon, 04 Jan 2016 20:52:16 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.9.0 4a236945e -> 5b5f002fc


MINOR: Add secondary constructor that takes only `props` in `KafkaConfig`

This fixes a compatibility break for users that use `new KafkaConfig(map)`
instead of `KafkaConfig(map)`.

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

Reviewers: Ewen Cheslack-Postava <ewen@confluent.io>

Closes #728 from ijuma/add-secondary-kafka-config-constructor


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

Branch: refs/heads/0.9.0
Commit: 5b5f002fceee7c1b16298b0eaf176ca49d98c025
Parents: 4a23694
Author: Ismael Juma <ismael@juma.me.uk>
Authored: Mon Jan 4 15:51:00 2016 -0500
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Mon Jan 4 15:51:00 2016 -0500

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/5b5f002f/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 0528e0e..2958c94 100755
--- a/core/src/main/scala/kafka/server/KafkaConfig.scala
+++ b/core/src/main/scala/kafka/server/KafkaConfig.scala
@@ -709,6 +709,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