From c1f45d218baee2fde3dcfaa724d711331413d8fc Mon Sep 17 00:00:00 2001
From: moonyoungCHAE <xpf_fl@naver.com>
Date: Fri, 14 Nov 2025 16:53:30 +0900
Subject: [PATCH] refactor example code

Signed-off-by: moonyoungCHAE <xpf_fl@naver.com>
---
 .../antora/modules/ROOT/pages/testing.adoc    | 22 +++++++++----------
 1 file changed, 10 insertions(+), 12 deletions(-)

diff --git a/spring-kafka-docs/src/main/antora/modules/ROOT/pages/testing.adoc b/spring-kafka-docs/src/main/antora/modules/ROOT/pages/testing.adoc
index 2742f4d092..c3a0c42416 100644
--- a/spring-kafka-docs/src/main/antora/modules/ROOT/pages/testing.adoc
+++ b/spring-kafka-docs/src/main/antora/modules/ROOT/pages/testing.adoc
@@ -158,21 +158,19 @@ public final class EmbeddedKafkaHolder {
     private static EmbeddedKafkaBroker embeddedKafka = new EmbeddedKafkaZKBroker(1, false)
             .brokerListProperty("spring.kafka.bootstrap-servers");
 
-    private static boolean started;
+    private static volatile boolean started;
 
     public static EmbeddedKafkaBroker getEmbeddedKafka() {
         if (!started) {
-            synchronized (this) {
-		if (!started) {
-		    try {
-	                embeddedKafka.afterPropertiesSet();
-		    }
-	            catch (Exception e) {
-	                throw new KafkaException("Embedded broker failed to start", e);
-		    }
-	            started = true;
-		}
-	    }
+            synchronized (EmbeddedKafkaBroker.class) {
+		    	try {
+	        		embeddedKafka.afterPropertiesSet();
+		    	}
+	        	catch (Exception e) {
+	        		throw new KafkaException("Embedded broker failed to start", e);
+		    	}
+	        	started = true;
+			}
         }
         return embeddedKafka;
     }