kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: Add INFO logging if ZK config is not specified
Date Mon, 16 May 2016 21:44:26 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 9a3fcf413 -> d54616bc3


MINOR: Add INFO logging if ZK config is not specified

Author: Guozhang Wang <wangguoz@gmail.com>

Reviewers: Ismael Juma

Closes #1392 from guozhangwang/Kminor-warn-no-zk-config


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

Branch: refs/heads/trunk
Commit: d54616bc31cec226cdb0ffd2003a41b4c27fdfed
Parents: 9a3fcf4
Author: Guozhang Wang <wangguoz@gmail.com>
Authored: Mon May 16 14:44:23 2016 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Mon May 16 14:44:23 2016 -0700

----------------------------------------------------------------------
 .../kafka/streams/processor/internals/StreamPartitionAssignor.java | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/d54616bc/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java
index f2eea36..085ff94 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java
@@ -124,6 +124,8 @@ public class StreamPartitionAssignor implements PartitionAssignor, Configurable
             internalTopicManager = new InternalTopicManager(
                     (String) configs.get(StreamsConfig.ZOOKEEPER_CONNECT_CONFIG),
                     configs.containsKey(StreamsConfig.REPLICATION_FACTOR_CONFIG) ? (Integer)
configs.get(StreamsConfig.REPLICATION_FACTOR_CONFIG) : 1);
+        } else {
+            log.info("Config '{}' isn't supplied and hence no internal topics will be created.",
StreamsConfig.ZOOKEEPER_CONNECT_CONFIG);
         }
     }
 


Mime
View raw message