| | |
|---|
| | | 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 TOPIC_SECOND_SPECIAL = "second_data_special"; |
|---|
| | | |
|---|
| | | } |
|---|
