From eb51b2364e9a3fbe806fde61fa255660a098fc8b Mon Sep 17 00:00:00 2001 From: kaiyu <404897439@qq.com> Date: Thu, 24 Jun 2021 14:06:41 +0800 Subject: [PATCH] Merge branch 'dev' of http://blit.7drlb.com:8888/r/moral into dev --- screen-common/src/main/java/com/moral/constant/KafkaConstants.java | 16 +++++++++++++--- 1 files changed, 13 insertions(+), 3 deletions(-) diff --git a/screen-common/src/main/java/com/moral/constant/KafkaConstants.java b/screen-common/src/main/java/com/moral/constant/KafkaConstants.java index 8f904d1..e1d6e80 100644 --- a/screen-common/src/main/java/com/moral/constant/KafkaConstants.java +++ b/screen-common/src/main/java/com/moral/constant/KafkaConstants.java @@ -5,15 +5,25 @@ /** * ������������������ */ - public static final String TOPIC_MINUTE = "test_topic"; + public static final String TOPIC_MINUTE = "minute"; /** * ������������������ */ public static final String TOPIC_HOUR = "hour"; + /* + * ��������������� + * */ + public static final String TOPIC_SECOND = "test"; + /** - * ��������� + * ������������������������������������������ */ - public static final String GROUP_ID = "test"; + public static final String GROUP_ID_INSERT = "insert"; + + /** + * ��������������������������������� + */ + public static final String GROUP_ID_STATE = "state"; } -- Gitblit v1.8.0