From d1db3d8e14022e1d5f60b161aff1344112bc3d0d Mon Sep 17 00:00:00 2001
From: Ken Huang <s7133700@gmail.com>
Date: Mon, 17 Feb 2025 14:38:20 +0800
Subject: [PATCH] KAFKA-18805: add synchronized block for Consumer Heartbeat
 close (#18920)

add synchronized block for Consumer Heartbeat close.

Reviewers: Luke Chen <showuon@gmail.com>
---
 .../kafka/clients/consumer/internals/AbstractCoordinator.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
index 9860d2f5890..b530ca562b9 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
@@ -1577,7 +1577,9 @@ public abstract class AbstractCoordinator implements Closeable {
                     this.failed.set(new RuntimeException(e));
             } finally {
                 log.debug("Heartbeat thread has closed");
-                this.closed = true;
+                synchronized (AbstractCoordinator.this) {
+                    this.closed = true;
+                }
             }
         }