diff --git a/src/main/java/com/xuxd/kafka/console/service/impl/TopicServiceImpl.java b/src/main/java/com/xuxd/kafka/console/service/impl/TopicServiceImpl.java index 099cd94..6bf3fc7 100644 --- a/src/main/java/com/xuxd/kafka/console/service/impl/TopicServiceImpl.java +++ b/src/main/java/com/xuxd/kafka/console/service/impl/TopicServiceImpl.java @@ -3,10 +3,8 @@ package com.xuxd.kafka.console.service.impl; import com.xuxd.kafka.console.beans.ResponseData; import com.xuxd.kafka.console.beans.vo.TopicDescriptionVO; import com.xuxd.kafka.console.service.TopicService; -import java.util.Arrays; import java.util.Comparator; import java.util.List; -import java.util.Set; import kafka.console.TopicConsole; import lombok.extern.slf4j.Slf4j; import org.apache.kafka.clients.admin.TopicDescription; @@ -31,7 +29,7 @@ public class TopicServiceImpl implements TopicService { } @Override public ResponseData getTopicList() { - List topicDescriptions = topicConsole.getTopicList(topicConsole.getTopicNameList()); + List topicDescriptions = topicConsole.getTopicList(topicConsole.getTopicNameList()); topicDescriptions.sort(Comparator.comparing(TopicDescription::name)); return ResponseData.create().data(topicDescriptions.stream().map(d -> TopicDescriptionVO.from(d))).success(); diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 3624bf4..31fad25 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -8,10 +8,10 @@ kafka: config: # kafka broker地址,多个以逗号分隔 # bootstrap-server: 'localhost:9092' - bootstrap-server: '10.100.64.48:9092,10.100.77.250:9092,10.100.73.154:9092' request-timeout-ms: 60000 # 服务端是否启用acl,如果不启用,下面的几项都忽略即可 enable-acl: true + # 只支持2种安全协议SASL_PLAINTEXT和PLAINTEXT,启用acl则设置为SASL_PLAINTEXT,不启用acl不需关心这个配置 security-protocol: SASL_PLAINTEXT sasl-mechanism: SCRAM-SHA-256 # 超级管理员用户名,在broker上已经配置为超级管理员 diff --git a/ui/src/App.vue b/ui/src/App.vue index 533db4a..ca9bf17 100644 --- a/ui/src/App.vue +++ b/ui/src/App.vue @@ -16,7 +16,7 @@ + + diff --git a/ui/src/views/op/Operation.vue b/ui/src/views/op/Operation.vue new file mode 100644 index 0000000..ccf95c7 --- /dev/null +++ b/ui/src/views/op/Operation.vue @@ -0,0 +1,17 @@ + + + + + diff --git a/ui/src/views/topic/Topic.vue b/ui/src/views/topic/Topic.vue index f2ec367..23aced0 100644 --- a/ui/src/views/topic/Topic.vue +++ b/ui/src/views/topic/Topic.vue @@ -1,18 +1,202 @@ - +