| | |
|---|
| | | 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 TOPIC_SECOND_SPECIAL = "second_data_special"; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 分钟主题消费组 |
|---|
| | | * 存入数据库的消费组 |
|---|
| | | */ |
|---|
| | | public static final String GROUP_MINUTE = "minute"; |
|---|
| | | public static final String GROUP_INSERT = "insert"; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 用于判断设备状态消费组 |
|---|
