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";
}