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

[ce...@apache.org]

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 <sa...@gmail.com>
AuthorDate: Fri Jun 30 22:09:37 2023 +0530

    [MINOR] Correcting few WARN log lines in DistributedHerder#handleRebalance (#13939)
    
    Reviewers: Chris Egerton <ch...@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.");