File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed
src/main/java/com/comcast/kafka/connect/kafka Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change @@ -195,7 +195,13 @@ private synchronized Set<LeaderTopicPartition> retrieveLeaderTopicPartitions(int
195195 logger .debug ("Server topic list: {}" , retrievedTopicSet );
196196 Set <String > matchedTopicSet = retrievedTopicSet .stream ().filter (topic -> matchedTopicFilter (topic ))
197197 .collect (Collectors .toSet ());
198- logger .debug ("Matched topic list: {}" , matchedTopicSet );
198+ if (matchedTopicSet .size () > 0 ) {
199+ logger .debug ("Matched topic list: {}" , matchedTopicSet );
200+ } else {
201+ logger .warn ("Provided pattern {} does currently not match any topic." +
202+ " Thus connector won't spawn any task until partition monitor recognizes matching topic." , this .topicWhitelistPattern .toString ());
203+
204+ }
199205
200206 DescribeTopicsOptions describeTopicsOptions = new DescribeTopicsOptions ()
201207 .timeoutMs ((int ) (requestTimeoutMs - (System .currentTimeMillis () - startWait )));
You can’t perform that action at this time.
0 commit comments