定时任务CO.O3算法

jinpengyong

2021-07-01 fdc8e1e781851904b05f234523f372c8c1098b69

 screen-common/src/main/java/com/moral/constant/KafkaConstants.java

@@ -5,15 +5,30 @@
    /**
     * 分钟数据主题
     */
    public static final String TOPIC_MINUTE = "test_topic";
    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 = "second_data";

    /**
     * 消费组
     * 小时主题消费组
     */
    public static final String GROUP_ID = "test";
    public static final String GROUP_HOUR = "hour";

    /**
     * 分钟主题消费组
     */
    public static final String GROUP_MINUTE = "minute";

    /**
     * 用于判断设备状态消费组
     */
    public static final String GROUP_STATE = "state";
}