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 409569db5b999..55a5bb2c528e8 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 @@ -1871,12 +1871,10 @@ boolean hasSubscriptionUpdates() { synchronized void updateSubscribedTopics(final Set topics, final String logPrefix) { - log.debug("{}found {} topics possibly matching subscription", logPrefix, topics); + log.debug("{}found {} topics possibly matching subscription", logPrefix, topics.size()); subscriptionUpdates.clear(); subscriptionUpdates.addAll(topics); - log.debug("{}updating builder with {} topic(s) with possible matching regex subscription(s)", - logPrefix, subscriptionUpdates); setRegexMatchedTopicsToSourceNodes(); setRegexMatchedTopicToStateStore(); }