From b390df08b513b06fb6087c6a9f0cab935bed5b7f Mon Sep 17 00:00:00 2001 From: zengqiao Date: Sat, 8 May 2021 11:28:52 +0800 Subject: [PATCH 1/3] =?UTF-8?q?faq=E8=A1=A5=E5=85=85app=E7=9A=84=E4=BD=BF?= =?UTF-8?q?=E7=94=A8=E8=AF=B4=E6=98=8E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- docs/user_guide/faq.md | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/docs/user_guide/faq.md b/docs/user_guide/faq.md index 25eeec2a..bf569fb2 100644 --- a/docs/user_guide/faq.md +++ b/docs/user_guide/faq.md @@ -24,6 +24,7 @@ - 12、逻辑集群申请审批通过之后为什么看不到逻辑集群？ - 13、heartbeat表关联业务和使用场景是什么？ - 14、集群的删除，是否会真正的删除集群？ +- 15、APP(应用)如何被使用起来？ --- @@ -145,3 +146,12 @@ KM支持HA的方式部署，那么部署多台的时候，就会出现每一台 ### 14、集群的删除，是否会真正的删除集群？ Logi-KM的运维管控，集群列表中的集群删除，仅仅只是将该集群从Logi-KM中进行删除，并不会对真正的物理集群做什么操作。 + + +### 15、APP(应用)如何被使用起来？ + +app在Logi-KM中可以近似理解为租户，或者是kafka里面的一个账号的概念。 + +界面中显示的app信息、权限信息等，在平台层面仅仅只是控制Topic或集群在平台上的可见性，如果使用的是社区版本的Kafka，那么实际上是不能真正的管控到客户端对Topic的生产和消费。 + +但是如果是使用的滴滴的Kafka-Gateway，那么是可以做到对客户端的生产和消费的权限管控。滴滴的Kafka-Gateway暂未开源，属于企业服务，具体的可以入群交流，群地址在README中。 From ed163a80e0750f0241c37f568822ab62d4d7812d Mon Sep 17 00:00:00 2001 From: zengqiao Date: Sat, 8 May 2021 11:45:27 +0800 Subject: [PATCH 2/3] bump commons-beanutils version to 1.9.4 --- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index 397bed74..9d4a5d30 100644 --- a/pom.xml +++ b/pom.xml @@ -215,7 +215,7 @@ commons-beanutils commons-beanutils - 1.9.3 + 1.9.4 From e342e646ff893beaa40b24055b24a39f2b793eaa Mon Sep 17 00:00:00 2001 From: zengqiao Date: Sat, 8 May 2021 13:50:04 +0800 Subject: [PATCH 3/3] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=9B=A0DB=E6=97=B6?= =?UTF-8?q?=E5=8C=BA=E4=B8=8D=E5=AF=B9=E5=AF=BC=E8=87=B4=E5=91=A8=E6=9C=9F?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E4=B8=8D=E8=83=BD=E8=A2=AB=E8=A7=A6=E5=8F=91?= =?UTF-8?q?=E7=9A=84=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../task/component/AbstractScheduledTask.java | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/AbstractScheduledTask.java b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/AbstractScheduledTask.java index b0700975..7eddb926 100644 --- a/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/AbstractScheduledTask.java +++ b/kafka-manager-task/src/main/java/com/xiaojukeji/kafka/manager/task/component/AbstractScheduledTask.java @@ -148,10 +148,12 @@ public abstract class AbstractScheduledTask implements Sch } Collections.sort(allTaskList); - List hostList = heartbeatDao.selectActiveHosts( - new Date(now - ScheduledTaskConstant.HEARTBEAT_TIME) - ); + List hostList = heartbeatDao.selectActiveHosts(new Date(now - ScheduledTaskConstant.HEARTBEAT_TIME)); if (ValidateUtils.isEmptyList(hostList)) { + // 当前无机器注册，导致周期任务(Topic指标存DB等任务)不可被触发执行。 + // 大概率原因可能是：DB的时区不对，注册的时间错误导致查询不出来。 + // 如果是单台方式部署的Logi-KM，那么也可能是服务新上线，或者是服务不正常导致的。 + LOGGER.error("customScheduled task running, but without registrant, and so scheduled tasks can't execute, scheduledName:{}.", scheduledName); return Lists.newArrayList(); } @@ -163,8 +165,10 @@ public abstract class AbstractScheduledTask implements Sch idx++; } if (idx == hostList.size()) { - // 当前机器未注册 - LOGGER.error("customScheduled task running, registers not conclude, scheduledName:{}.", scheduledName); + // 当前机器未注册, 原因可能是： + // 1、当前服务新上线，确实暂未注册到DB中。 + // 2、当前服务异常，比如进行FGC等，导致注册任务停止了。 + LOGGER.warn("customScheduled task running, registrants not conclude present machine, scheduledName:{}.", scheduledName); return Lists.newArrayList(); }