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 GROUP_HOUR = "hour";
|
|
/**
|
* 分钟主题消费组
|
*/
|
public static final String GROUP_MINUTE = "minute";
|
|
/**
|
* 用于判断设备状态消费组
|
*/
|
public static final String GROUP_STATE = "state";
|
}
|
