[kafka] branch trunk updated: [MINOR] Correcting few WARN log lines in DistributedHerder#handleRebalance (#13939)

[cegerton]

This is an automated email from the ASF dual-hosted git repository.

cegerton pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 96e59d7bfd6 [MINOR] Correcting few WARN log lines in 
DistributedHerder#handleRebalance (#13939)
96e59d7bfd6 is described below

commit 96e59d7bfd631366bc84d20a5dbf7ca98eeb5d09
Author: vamossagar12 <sagarmeansoc...@gmail.com>
AuthorDate: Fri Jun 30 22:09:37 2023 +0530

    [MINOR] Correcting few WARN log lines in DistributedHerder#handleRebalance 
(#13939)
    
    Reviewers: Chris Egerton <chr...@aiven.io>
---
 .../org/apache/kafka/connect/runtime/distributed/DistributedHerder.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
 
b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
index 5f497f1e118..1de487245e0 100644
--- 
a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
+++ 
b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
@@ -1660,7 +1660,7 @@ public class DistributedHerder extends AbstractHerder 
implements Runnable {
                 log.warn("Join group completed, but 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 assignment failed and we 
are lagging. Reading to end of config and retrying.");
                 needsReadToEnd = true;
             } else {
                 log.warn("Join group completed, but assignment failed. We were 
up to date, so just retrying.");