package com.moral.constant;

public class KafkaConstants {

    /**
     * 普通设备分钟数据主题
     */
    public static final String TOPIC_MINUTE = "minute_data";

    /**
     * 普通设备小时数据主题
     */
    public static final String TOPIC_HOUR = "hour_data";

    /*
     * 普通设备秒数据主题
     * */
    public static final String TOPIC_SECOND = "second_data";

    /**
     * 无人机秒数据主题
     */
    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";

}