[fix]kafkaadmin支持SASL方式连接

src/main/java/com/viontech/keliu/config/KafkaAdminConfig.java

+package com.viontech.keliu.config;
+
+import org.apache.kafka.clients.admin.AdminClient;
+import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @ClassName KafkaAdminConfig
+ * @Description TODO
+ * @Author pengfei
+ * @Date 2025/12/15
+ **/
+@Configuration
+public class KafkaAdminConfig {
+
+    @Bean
+    public AdminClient adminClient(KafkaProperties kafkaProperties) {
+        return AdminClient.create(kafkaProperties.buildAdminProperties());
+    }
+}

src/main/java/com/viontech/keliu/service/KafkaTopicService.java

@@ -8,6 +8,7 @@ import org.apache.kafka.clients.admin.ListOffsetsResult;
 import org.apache.kafka.clients.admin.OffsetSpec;
 import org.apache.kafka.clients.admin.TopicDescription;
 import org.apache.kafka.common.TopicPartition;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.kafka.core.KafkaAdmin;
 import org.springframework.stereotype.Service;
 
@@ -28,11 +29,12 @@ import java.util.stream.Collectors;
 @Slf4j
 public class KafkaTopicService {
 
-    private final AdminClient adminClient;
+    @Autowired
+    private AdminClient adminClient;
 
-    public KafkaTopicService(KafkaAdmin kafkaAdmin) {
-        this.adminClient = AdminClient.create(kafkaAdmin.getConfigurationProperties());
-    }
+    // public KafkaTopicService(KafkaAdmin kafkaAdmin) {
+    //     this.adminClient = AdminClient.create(kafkaAdmin.getConfigurationProperties());
+    // }
 
     /**
      * 首先匹配指定正则表达式的topic，然后根据topic中日期进行过滤，最后删除匹配的topic，如果topic中没有数据，则删除该topic