From 54dc3b969e8aaf8e29ec7ad0f3545d3f32a2049c Mon Sep 17 00:00:00 2001 From: MaxKey Date: Sat, 17 Jul 2021 10:34:17 +0800 Subject: [PATCH] MXK_TOPICS --- gradle.properties | 2 +- .../persistence/kafka/KafkaIdentityTopic.java | 21 +++++++++++++++---- 2 files changed, 18 insertions(+), 5 deletions(-) diff --git a/gradle.properties b/gradle.properties index 2d09e5919..75cb728ed 100644 --- a/gradle.properties +++ b/gradle.properties @@ -33,7 +33,7 @@ commonscompressVersion =1.20 log4jVersion =2.14.1 kafkaclientsVersion =2.6.1 poiVersion =4.1.2 -tomcatVersion =9.0.46 +tomcatVersion =9.0.50 tomcatembedloggingjuliVersion =8.5.2 #spring springVersion =5.3.9 diff --git a/maxkey-persistence/src/main/java/org/maxkey/persistence/kafka/KafkaIdentityTopic.java b/maxkey-persistence/src/main/java/org/maxkey/persistence/kafka/KafkaIdentityTopic.java index 645caa311..238d83e03 100644 --- a/maxkey-persistence/src/main/java/org/maxkey/persistence/kafka/KafkaIdentityTopic.java +++ b/maxkey-persistence/src/main/java/org/maxkey/persistence/kafka/KafkaIdentityTopic.java @@ -19,13 +19,26 @@ package org.maxkey.persistence.kafka; public class KafkaIdentityTopic { - public final static String USERINFO_TOPIC = "IDENTITY_USERINFO_TOPIC"; + public final static String USERINFO_TOPIC = "MXK_IDENTITY_USERINFO_TOPIC"; - public final static String ORG_TOPIC = "IDENTITY_ORG_TOPIC"; + public final static String PASSWORD_TOPIC = "MXK_IDENTITY_USERINFO_PASSWORD_TOPIC"; - public final static String GROUP_TOPIC = "IDENTITY_GROUP_TOPIC"; + public final static String ORG_TOPIC = "MXK_IDENTITY_ORG_TOPIC"; - public final static String PASSWORD_TOPIC = "IDENTITY_PASSWORD_TOPIC"; + public final static String GROUP_TOPIC = "MXK_IDENTITY_GROUP_TOPIC"; + public final static String GROUP_MEMBER_TOPIC = "MXK_IDENTITY_GROUP_MEMBER_TOPIC"; + public final static String ACCOUNT_TOPIC = "MXK_IDENTITY_ACCOUNT_TOPIC"; + + public final static String AUTHORITY_ROLE_TOPIC = "MXK_AUTHORITY_ROLE_TOPIC"; + + public final static String AUTHORITY_ROLE_MEMBER_TOPIC = "MXK_AUTHORITY_ROLE_MEMBER_TOPIC"; + + public final static String AUTHORITY_RESOURCE_TOPIC = "MXK_AUTHORITY_RESOURCE_TOPIC"; + + public final static String AUTHORITY_ROLE_PERMISSION_TOPIC = "MXK_AUTHORITY_ROLE_PERMISSION_TOPIC"; + + public final static String CONNECTOR_HISTORY_TOPIC = "MXK_CONNECTOR_HISTORY_TOPIC"; + }