From 47b6c5d86a875c802dda2bd35a67a7b391d554c6 Mon Sep 17 00:00:00 2001 From: duanxiaoqiu Date: Sat, 26 Nov 2022 18:09:14 +0800 Subject: [PATCH] =?UTF-8?q?[Bugfix]=E4=BF=AE=E5=A4=8D=E5=88=9B=E5=BB=BAtop?= =?UTF-8?q?ic=E9=80=89=E6=8B=A9=E8=BF=87=E6=9C=9F=E7=AD=96=E7=95=A5(kafka?= =?UTF-8?q?=E7=89=88=E6=9C=AC0.10.1.0=E4=B9=8B=E5=89=8D)compact=E5=92=8Cde?= =?UTF-8?q?lete=E5=8F=AA=E8=83=BD=E4=BA=8C=E9=80=89=E4=B8=80(didi#770)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/version/fe/FrontEndControlVersionItems.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/fe/FrontEndControlVersionItems.java b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/fe/FrontEndControlVersionItems.java index 4daa465b..769bd225 100644 --- a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/fe/FrontEndControlVersionItems.java +++ b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/fe/FrontEndControlVersionItems.java @@ -31,6 +31,8 @@ public class FrontEndControlVersionItems extends BaseMetricVersionMetric { private static final String FE_SECURITY_ACL_CREATE_RESOURCE_TYPE_TRANSACTIONAL_ID = "FESecurityAclCreateResourceTypeTransactionalId"; private static final String FE_SECURITY_ACL_CREATE_RESOURCE_TYPE_DELEGATION_TOKEN = "FESecurityAclCreateResourceTypeDelegationToken"; + private static final String FE_CREATE_TOPIC_CLEANUP_POLICY = "FECreateTopicCleanupPolicy"; + public FrontEndControlVersionItems(){} @Override @@ -74,6 +76,10 @@ public class FrontEndControlVersionItems extends BaseMetricVersionMetric { itemList.add(buildItem().minVersion(VersionEnum.V_1_1_0).maxVersion(VersionEnum.V_MAX) .name(FE_SECURITY_ACL_CREATE_RESOURCE_TYPE_DELEGATION_TOKEN).desc("Security-创建ACL-ResourceType-DelegationToken")); + // topic-创建-清理策略(delete和compact)V_0_10_1_0都可以选择 + itemList.add(buildItem().minVersion(VersionEnum.V_0_10_1_0).maxVersion(VersionEnum.V_MAX) + .name(FE_CREATE_TOPIC_CLEANUP_POLICY).desc("Topic-创建Topic-Cleanup-Policy")); + return itemList; } }