KafkaConstants.java 1.36 KB
package com.viontech.keliu.constants;

public class KafkaConstants {
    // 商业人脸抓拍重试topic
    public static final String TOPIC_STORE_RETRY_FACECAPTURE = "Store_Retry_FaceCapture";
    // 商业人员标签重试topic
    public static final String TOPIC_STORE_RETRY_PERSONLABEL = "Store_Retry_PersonLabel";
    /**
     * d_gate_minute_count_data统计数据的topic
     */
    public static final String STORE_GATE_MINUTE_COUNT_DATA_TOPIC = "Store_gate_minute_count_data";
    /**
     * d_gate_hour_count_data统计数据的topic
     */
    public static final String STORE_GATE_HOUR_COUNT_DATA_TOPIC = "Store_gate_hour_count_data";
    /**
     * d_gate_day_count_data统计数据的topic
     */
    public static final String STORE_GATE_DAY_COUNT_DATA_TOPIC = "Store_gate_day_count_data";
    /**
     * d_zone_minute_count_data统计数据的topic
     */
    public static final String STORE_ZONE_MINUTE_COUNT_DATA_TOPIC = "Store_zone_minute_count_data";
    /**
     * d_zone_hour_count_data统计数据的topic
     */
    public static final String STORE_ZONE_HOUR_COUNT_DATA_TOPIC = "Store_zone_hour_count_data";
    /**
     * d_zone_day_count_data统计数据的topic
     */
    public static final String STORE_ZONE_DAY_COUNT_DATA_TOPIC = "Store_zone_day_count_data";

    public static final String STORE_DATA_STATISTICS_TOPIC = "Store_dataStatistics";
}