From 9cc9f173f8db89135610eba2c8af79c17b24dfdf Mon Sep 17 00:00:00 2001 From: kaiyu <404897439@qq.com> Date: Wed, 08 Sep 2021 17:21:19 +0800 Subject: [PATCH] screen-api 增加获取组织所有无人机飞行时间接口 --- screen-common/src/main/java/com/moral/constant/KafkaConstants.java | 44 ++++++++++++++++++++++++++++++++++++++------ 1 files changed, 38 insertions(+), 6 deletions(-) diff --git a/screen-common/src/main/java/com/moral/constant/KafkaConstants.java b/screen-common/src/main/java/com/moral/constant/KafkaConstants.java index 8f904d1..3f58d3c 100644 --- a/screen-common/src/main/java/com/moral/constant/KafkaConstants.java +++ b/screen-common/src/main/java/com/moral/constant/KafkaConstants.java @@ -3,17 +3,49 @@ 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"; + } -- Gitblit v1.8.0