From 96e59d7bfd631366bc84d20a5dbf7ca98eeb5d09 Mon Sep 17 00:00:00 2001 From: vamossagar12 Date: Fri, 30 Jun 2023 22:09:37 +0530 Subject: [PATCH] [MINOR] Correcting few WARN log lines in DistributedHerder#handleRebalance (#13939) Reviewers: Chris Egerton --- .../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.");