Repository: kafka Updated Branches: refs/heads/0.10.0 8d38c115a -> 73ec226d3
MINOR: Add INFO logging if ZK config is not specified Author: Guozhang Wang <[email protected]> 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/c052002e Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c052002e Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c052002e Branch: refs/heads/0.10.0 Commit: c052002e75bfa6c835ca3d0654e806c998e0fce3 Parents: 9ba2fdf Author: Guozhang Wang <[email protected]> Authored: Mon May 16 14:44:23 2016 -0700 Committer: Guozhang Wang <[email protected]> Committed: Sat Jun 18 11:45:29 2016 -0700 ---------------------------------------------------------------------- .../kafka/streams/processor/internals/StreamPartitionAssignor.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/c052002e/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); } }
