| | |
|---|
| | | public class KafkaConstants { |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 分钟数据主题 |
|---|
| | | * 普通设备分钟数据主题 |
|---|
| | | */ |
|---|
| | | public static final String TOPIC_MINUTE = "test_topic"; |
|---|
| | | public static final String TOPIC_MINUTE = "minute_data"; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 小时数据主题 |
|---|
| | | * 普通设备小时数据主题 |
|---|
| | | */ |
|---|
| | | public static final String TOPIC_HOUR = "hour"; |
|---|
| | | public static final String TOPIC_HOUR = "hour_data"; |
|---|
| | | |
|---|
| | | /* |
|---|
| | | * 普通设备秒数据主题 |
|---|
| | | * */ |
|---|
| | | public static final String TOPIC_SECOND = "second_data"; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 消费组 |
|---|
| | | * 无人机秒数据主题 |
|---|
| | | */ |
|---|
| | | public static final String GROUP_ID = "test"; |
|---|
| | | 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"; |
|---|
| | | |
|---|
| | | } |
|---|
