diff --git a/docs/user_guide/faq.md b/docs/user_guide/faq.md index 25eeec2a5757a24dabb8325639ade0fa03fcb039..bf569fb2f00a0269d165d35b9f9d70b583f91fb1 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中。 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 b070097590db53e1d8432e26e1c8fc2817ddb3b7..7eddb926684a7f76d3cdead1339a9b03f8a3496b 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(); } diff --git a/pom.xml b/pom.xml index 397bed7416317e63d7dfb8b9d1363033f28c228b..9d4a5d302078ec6facc710ab4d1351b6c562f4f1 100644 --- a/pom.xml +++ b/pom.xml @@ -215,7 +215,7 @@ commons-beanutils commons-beanutils - 1.9.3 + 1.9.4