diff --git a/src/main/java/com/xuxd/kafka/console/service/impl/ConsumerServiceImpl.java b/src/main/java/com/xuxd/kafka/console/service/impl/ConsumerServiceImpl.java index a40c97d..eb47edf 100644 --- a/src/main/java/com/xuxd/kafka/console/service/impl/ConsumerServiceImpl.java +++ b/src/main/java/com/xuxd/kafka/console/service/impl/ConsumerServiceImpl.java @@ -142,7 +142,7 @@ public class ConsumerServiceImpl implements ConsumerService { @Override public ResponseData resetOffsetByDate(String groupId, String topic, String dateStr) { long timestamp = -1L; try { - StringBuilder sb = new StringBuilder(dateStr.replace(" ", "T")).append(".000"); + StringBuilder sb = new StringBuilder(dateStr.replace(" ", "T")).append(".000+08:00");//固定为utc+08:00东8区来计算 timestamp = Utils.getDateTime(sb.toString()); } catch (ParseException e) { throw new IllegalArgumentException(e); diff --git a/ui/src/views/group/ConsumerDetail.vue b/ui/src/views/group/ConsumerDetail.vue index 01a83fd..4667220 100644 --- a/ui/src/views/group/ConsumerDetail.vue +++ b/ui/src/views/group/ConsumerDetail.vue @@ -70,6 +70,11 @@ +

+ 注意:重置位点时,要求当前没有正在运行的消费端,否则重置的时候会报错,返回失败信息 +

+
+

+ *注意:该时间为北京时间。这里固定为东8区的计算时间,如果所在地区不是采用北京时间(中国大部分地区都是采用的北京时间),请自行对照为当地时间重置。 +

diff --git a/ui/src/views/op/Operation.vue b/ui/src/views/op/Operation.vue index 90fe33e..08b2bdc 100644 --- a/ui/src/views/op/Operation.vue +++ b/ui/src/views/op/Operation.vue @@ -30,7 +30,9 @@ 将集群中所有分区leader副本设置为首选副本

- 副本变更详情 + + 副本变更详情 + 查看正在进行副本变更/重分配的任务,或者将其取消

@@ -183,6 +185,9 @@ export default { closeRemoveThrottleDialog() { this.brokerManager.showRemoveThrottleDialog = false; }, + openReplicaReassignmentDetailDialog() { + this.$message.info("此功能尚不支持,下个版本支持"); + }, }, }; diff --git a/ui/src/views/topic/Topic.vue b/ui/src/views/topic/Topic.vue index e5c7bb9..0981285 100644 --- a/ui/src/views/topic/Topic.vue +++ b/ui/src/views/topic/Topic.vue @@ -295,7 +295,7 @@ export default { this.showUpdateReplicaDialog = false; }, openMessageStatsDialog() { - this.$message.info("此功能尚不支持"); + this.$message.info("此功能尚不支持,下个版本支持"); }, openThrottleDialog(topic) { this.showThrottleDialog = true;