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"; }
