screen-common/src/main/java/com/moral/constant/KafkaConstants.java
@@ -5,17 +5,17 @@ /** * 分钟数据主题 */ public static final String TOPIC_MINUTE = "minute"; public static final String TOPIC_MINUTE = "minute_data"; /** * 小时数据主题 */ public static final String TOPIC_HOUR = "hour"; public static final String TOPIC_HOUR = "hour_data"; /* * 秒数据主题 * */ public static final String TOPIC_SECOND = "test"; public static final String TOPIC_SECOND = "second_data"; /** * 用于将数据存入数据库的消费组
