特殊设备数据insert

jinpengyong

2021-08-17 6f4e852b84c577454a4876f83c7085bd360fe4fb

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

@@ -3,27 +3,32 @@
public class KafkaConstants {

    /**
     * 分钟数据主题
     * 普通设备分钟数据主题
     */
    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";

    /**
     * 用于将数据存入数据库的消费组
     * 无人机，走航车等特殊设备秒数据主题
     */
    public static final String GROUP_ID_INSERT = "insert";
    public static final String TOPIC_SECOND_SPECIAL = "second_data_special";

    /**
     * 存入数据库的消费组
     */
    public static final String GROUP_INSERT = "insert";

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