C0urante commented on code in PR #15906:
URL: https://github.com/apache/kafka/pull/15906#discussion_r1595516663
##########
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/DedicatedMirrorIntegrationTest.java:
##########
@@ -260,9 +261,8 @@ public void testMultiNodeCluster() throws Exception {
awaitConnectorTasksStart(mirrorMakers.get("node 0"),
MirrorHeartbeatConnector.class, sourceAndTarget);
// Create one topic per Kafka cluster per MirrorMaker node
- final int topicsPerCluster = numNodes;
Review Comment:
With cosmetic changes like this, please watch out so that comments don't
become stale. The `// Create one topic per Kafka cluster...` comment should be
moved to just above the for-loop since it has nothing to do with the
`messagesPerTopic` declaration.
--
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
