yashmayya commented on code in PR #14827:
URL: https://github.com/apache/kafka/pull/14827#discussion_r1405642306


##########
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/ConnectAssertions.java:
##########
@@ -524,7 +524,7 @@ public void assertConnectorIsStopped(String connectorName, 
String detailMessage)
      * @param connectorState
      * @param numTasks the expected number of tasks
      * @param tasksState
-     * @return true if the connector and tasks are in RUNNING state; false 
otherwise
+     * @return true if the connector and tasks are in expected states; false 
otherwise

Review Comment:
   ```suggestion
        * @return true if the connector and tasks are in the expected state; 
false otherwise
   ```
   nit: they're all expected to be in the same state



-- 
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

Reply via email to