screen-common/src/main/java/com/moral/constant/KafkaConstants.java
@@ -18,12 +18,17 @@ public static final String TOPIC_SECOND = "second_data"; /** * 用于将数据存入数据库的消费组 * 小时主题消费组 */ public static final String GROUP_ID_INSERT = "insert"; public static final String GROUP_HOUR = "hour"; /** * 分钟主题消费组 */ public static final String GROUP_MINUTE = "minute"; /** * 用于判断设备状态消费组 */ public static final String GROUP_ID_STATE = "state"; public static final String GROUP_STATE = "state"; }
