8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 11:52:08 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

增加返回Kafka内部Topic

Browse Source
This commit is contained in:
zengqiao
2022-08-25 19:49:47 +08:00
parent a73484d23a
commit 65a16d058a
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java
View File

@@ -372,7 +372,7 @@ public class PartitionServiceImpl extends BaseVersionControlService implements P
AdminClient adminClient = kafkaAdminClient.getClient(clusterPhy.getId());
// 获取Topic列表
ListTopicsResult listTopicsResult = adminClient.listTopics(new ListTopicsOptions().timeoutMs(KafkaConstant.ADMIN_CLIENT_REQUEST_TIME_OUT_UNIT_MS));
ListTopicsResult listTopicsResult = adminClient.listTopics(new ListTopicsOptions().timeoutMs(KafkaConstant.ADMIN_CLIENT_REQUEST_TIME_OUT_UNIT_MS).listInternal(true));
for (String topicName: listTopicsResult.names().get()) {
DescribeTopicsResult describeTopicsResult = adminClient.describeTopics(
Arrays.asList(topicName),

2
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicServiceImpl.java
View File

@@ -238,7 +238,7 @@ public class TopicServiceImpl implements TopicService {
try {
AdminClient adminClient = kafkaAdminClient.getClient(clusterPhy.getId());
ListTopicsResult listTopicsResult = adminClient.listTopics(new ListTopicsOptions().timeoutMs(KafkaConstant.ADMIN_CLIENT_REQUEST_TIME_OUT_UNIT_MS));
ListTopicsResult listTopicsResult = adminClient.listTopics(new ListTopicsOptions().timeoutMs(KafkaConstant.ADMIN_CLIENT_REQUEST_TIME_OUT_UNIT_MS).listInternal(true));
List<Topic> topicList = new ArrayList<>();