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);