OmniaGM commented on code in PR #15968:
URL: https://github.com/apache/kafka/pull/15968#discussion_r2032967770
##########
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java:
##########
@@ -169,6 +169,9 @@ public void start(Map<String, String> props) {
"refreshing topics");
log.info("Started {} with {} topic-partitions.", connectorName,
knownSourceTopicPartitions.size());
log.info("Starting {} took {} ms.", connectorName,
System.currentTimeMillis() - start);
+
+ // your topics -> destination
+ // __offset-sync-topic
Review Comment:
same they were committed by mistake. Was explaining to someone how MM2 works
while do the rebase and forgot them :(
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
