From 73e72c8526591044120d39af7c56c023f7f8d9f8 Mon Sep 17 00:00:00 2001
From: Shikong <919411476@qq.com>
Date: Tue, 25 Apr 2023 15:00:48 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../study/springcloud/kafka/tests/KafkaConfigTest.java      | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/kafka-01/kafka-01-producer/src/test/java/cn/skcks/study/springcloud/kafka/tests/KafkaConfigTest.java b/kafka-01/kafka-01-producer/src/test/java/cn/skcks/study/springcloud/kafka/tests/KafkaConfigTest.java
index 1959f32..3e43922 100644
--- a/kafka-01/kafka-01-producer/src/test/java/cn/skcks/study/springcloud/kafka/tests/KafkaConfigTest.java
+++ b/kafka-01/kafka-01-producer/src/test/java/cn/skcks/study/springcloud/kafka/tests/KafkaConfigTest.java
@@ -44,10 +44,14 @@ public class KafkaConfigTest {
         log.info("StreamsProperties {}", JsonUtils.toJson(streamsProperties));
     }
 
+    private AdminClient adminClient(){
+        return AdminClient.create(kafkaProperties.buildAdminProperties());
+    }
+
     @Test
     @SneakyThrows
     void topics() {
-        try (AdminClient adminClient = AdminClient.create(kafkaProperties.buildAdminProperties())) {
+        try (AdminClient adminClient = adminClient()) {
             ListTopicsOptions options = new ListTopicsOptions();
             // 包含内置主题
             options.listInternal(true);