Shikong/springcloud-study
1
0
Fork 0
mirror of https://gitee.com/shikong-sk/springcloud-study synced 2025-02-22 21:32:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

调整

Browse Source
This commit is contained in:
Shikong 2023-04-25 15:00:48 +08:00
parent e4ebff30b9
commit 73e72c8526
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
kafka-01/kafka-01-producer/src/test/java/cn/skcks/study/springcloud/kafka/tests/KafkaConfigTest.java
View File

@ -44,10 +44,14 @@ public class KafkaConfigTest {
log.info("StreamsProperties {}", JsonUtils.toJson(streamsProperties)); log.info("StreamsProperties {}", JsonUtils.toJson(streamsProperties));
} }
private AdminClient adminClient(){
return AdminClient.create(kafkaProperties.buildAdminProperties());
}
@Test @Test
@SneakyThrows @SneakyThrows
void topics() { void topics() {
try (AdminClient adminClient = AdminClient.create(kafkaProperties.buildAdminProperties())) { try (AdminClient adminClient = adminClient()) {
ListTopicsOptions options = new ListTopicsOptions(); ListTopicsOptions options = new ListTopicsOptions();
// 包含内置主题 // 包含内置主题
options.listInternal(true); options.listInternal(true);