From 6291d5cac7e13d7bbd0c65ce1e08afb4b2a367ca Mon Sep 17 00:00:00 2001 From: majialong Date: Sat, 29 Nov 2025 18:03:28 +0800 Subject: [PATCH] MINOR: Ensure proper visibility of attribute accesses across thread --- .../kafka/coordinator/common/runtime/CoordinatorRuntime.java | 2 +- .../apache/kafka/coordinator/group/GroupCoordinatorService.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java b/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java index 901acd3d7fd07..fb94cb05942ed 100644 --- a/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java +++ b/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java @@ -571,7 +571,7 @@ class CoordinatorContext { /** * The current state. */ - CoordinatorState state; + volatile CoordinatorState state; /** * The current epoch of the coordinator. This represents diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java index 4e0e03265a6ce..79e5b8e28591b 100644 --- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java +++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java @@ -331,7 +331,7 @@ public GroupCoordinatorService build() { * The metadata image to extract topic id to names map. * This is initialised when the {@link GroupCoordinator#onNewMetadataImage(MetadataImage, MetadataDelta)} is called */ - private MetadataImage metadataImage = null; + private volatile MetadataImage metadataImage = null; /** *