KafkaConstants.java
1.34 KB
package com.viontech.keliu.constants;
public class KafkaConstants {
// 商业人脸抓拍重试topic
public static final String TOPIC_MALL_RETRY_FACECAPTURE = "Mall_Retry_FaceCapture";
// 商业人员标签重试topic
public static final String TOPIC_MALL_RETRY_PERSONLABEL = "Mall_Retry_PersonLabel";
/**
* d_gate_minute_count_data统计数据的topic
*/
public static final String MALL_GATE_MINUTE_COUNT_DATA_TOPIC = "Mall_gate_minute_count_data";
/**
* d_gate_hour_count_data统计数据的topic
*/
public static final String MALL_GATE_HOUR_COUNT_DATA_TOPIC = "Mall_gate_hour_count_data";
/**
* d_gate_day_count_data统计数据的topic
*/
public static final String MALL_GATE_DAY_COUNT_DATA_TOPIC = "Mall_gate_day_count_data";
/**
* d_zone_minute_count_data统计数据的topic
*/
public static final String MALL_ZONE_MINUTE_COUNT_DATA_TOPIC = "Mall_zone_minute_count_data";
/**
* d_zone_hour_count_data统计数据的topic
*/
public static final String MALL_ZONE_HOUR_COUNT_DATA_TOPIC = "Mall_zone_hour_count_data";
/**
* d_zone_day_count_data统计数据的topic
*/
public static final String MALL_ZONE_DAY_COUNT_DATA_TOPIC = "Mall_zone_day_count_data";
public static final String MALL_DATA_STATISTICS_TOPIC = "Mall_dataStatistics";
}