package com.moral.constant;

public class KafkaConstants {

    /**
     * 分钟数据主题
     */
    public static final String TOPIC_MINUTE = "minute";

    /**
     * 小时数据主题
     */
    public static final String TOPIC_HOUR = "hour";

    /*
     * 秒数据主题
     * */
    public static final String TOPIC_SECOND = "test";

    /**
     * 用于将数据存入数据库的消费组
     */
    public static final String GROUP_ID_INSERT = "insert";

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