kaiyu
2021-08-31 a3646e32c81cd62886405a77c4c89aad7fb857e7
screen-common
更新kafka主题名称常量类
1 files modified
30 ■■■■■ changed files
screen-common/src/main/java/com/moral/constant/KafkaConstants.java 30 ●●●●● patch | view | raw | blame | history
screen-common/src/main/java/com/moral/constant/KafkaConstants.java
@@ -18,8 +18,34 @@
    public static final String TOPIC_SECOND = "second_data";
    /**
     * 无人机,走航车等特殊设备秒数据主题
     * 无人机秒数据主题
     */
    public static final String TOPIC_SECOND_SPECIAL = "second_data_special";
    public static final String UAV_TOPIC_SECOND = "uav_second_data";
    /*
    * 走航车秒级数据主题
    * */
    public static final String CRUISER_TOPIC_SECOND = "cruiser_second_data";
    /*
    * 走航车分钟数据主题
    * */
    public static final String CRUISER_TOPIC_MINUTE = "cruiser_minute_data";
    /*
    * 走航车小时数据主题
    * */
    public static final String CRUISER_TOPIC_HOUR = "cruiser_hour_data";
    /**
     * 存入数据库的消费组
     */
    public static final String GROUP_INSERT = "insert";
    /**
     * 用于判断设备状态消费组
     */
    public static final String GROUP_STATE = "state";
    
}