[kafka] branch 1.1 updated: MINOR: Fixed log in Topology Builder. (#5483)

[mj...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/1.1 by this push:
     new 028edc2  MINOR: Fixed log in Topology Builder. (#5483)
028edc2 is described below

commit 028edc286491e8d85fd340da86f7a7d03880900d
Author: Kamal Chandraprakash <ka...@gmail.com>
AuthorDate: Thu Aug 9 10:58:26 2018 +0530

    MINOR: Fixed log in Topology Builder. (#5483)
    
    Reviewers: Viktor Somogyi <vi...@gmail.com>, Satish Duggana <sa...@apache.org>, Matthias J. Sax <ma...@confluent.io>
---
 .../kafka/streams/processor/internals/InternalTopologyBuilder.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
index a9d5a93..71a6b8a 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
@@ -1878,7 +1878,7 @@ public class InternalTopologyBuilder {
 
     public void updateSubscribedTopics(final Set<String> topics, final String logPrefix) {
         final SubscriptionUpdates subscriptionUpdates = new SubscriptionUpdates();
-        log.debug("{}found {} topics possibly matching regex", topics, logPrefix);
+        log.debug("{}found {} topics possibly matching regex", logPrefix, topics);
         // update the topic groups with the returned subscription set for regex pattern subscriptions
         subscriptionUpdates.updateTopics(topics);
         updateSubscriptions(subscriptionUpdates, logPrefix);