[GitHub] [kafka] vamossagar12 commented on a diff in pull request #13939: [MINOR] Correcting few WARN log lines in DistributedHerder#handleRebalance

["vamossagar12 (via GitHub)" <gi...@apache.org>]

vamossagar12 commented on code in PR #13939:
URL: https://github.com/apache/kafka/pull/13939#discussion_r1248058129


##########
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java:
##########
@@ -1657,13 +1657,13 @@ private boolean handleRebalanceCompleted() {
         if (assignment.failed()) {
             needsRejoin = true;
             if (isLeader()) {
-                log.warn("Join group completed, but assignment failed and we are the leader. Reading to end of config and retrying.");
+                log.warn("Join group completed, but the assignment failed and we are the leader. Reading to end of config and retrying.");
                 needsReadToEnd = true;
             } else if (configState.offset() < assignment.offset()) {
-                log.warn("Join group completed, but assignment failed and we lagging. Reading to end of config and retrying.");
+                log.warn("Join group completed, but the assignment failed and we are lagging. Reading to end of config and retrying.");

Review Comment:
   Removed the unwanted changes.



-- 
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-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org