You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ew...@apache.org on 2016/01/04 21:52:16 UTC
kafka git commit: MINOR: Add secondary constructor that takes only
`props` in `KafkaConfig`
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 <is...@juma.me.uk>
Reviewers: Ewen Cheslack-Postava <ew...@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 <is...@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)