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 <[email protected]>
AuthorDate: Thu Aug 9 10:58:26 2018 +0530
MINOR: Fixed log in Topology Builder. (#5483)
Reviewers: Viktor Somogyi <[email protected]>, Satish Duggana
<[email protected]>, Matthias J. Sax <[email protected]>
---
.../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);
