package com.fs.common.constant;

/**
 * RocketMQ常量
 *
 * @author zhangqin
 * @date 2025-11-05
 */
public class RocketMqConstant {

    /**
     * Topic: 转化回传
     */
    public static final String TOPIC_CONVERSION_CALLBACK = "CONVERSION_CALLBACK_TOPIC";

    /**
     * Topic: 事件反馈（表单提交等转化事件）
     */
    public static final String TOPIC_EVENT_FEEDBACK = "event-feedback";

    /**
     * Topic: 点击追踪
     */
    public static final String TOPIC_CLICK_TRACE = "CLICK_TRACE_TOPIC";

    /**
     * Topic: 数据同步
     */
    public static final String TOPIC_DATA_SYNC = "DATA_SYNC_TOPIC";

    /**
     * Consumer Group: 转化回传消费组
     */
    public static final String CONSUMER_GROUP_CONVERSION = "conversion-consumer-group";

    /**
     * Consumer Group: 事件反馈消费组
     */
    public static final String CONSUMER_GROUP_EVENT_FEEDBACK = "event-feedback-consumer-group";

    /**
     * Consumer Group: 点击追踪消费组
     */
    public static final String CONSUMER_GROUP_CLICK_TRACE = "click-trace-consumer-group";

    /**
     * Consumer Group: 数据同步消费组
     */
    public static final String CONSUMER_GROUP_DATA_SYNC = "data-sync-consumer-group";

    /**
     * Consumer Group: 死信队列消费组
     */
    public static final String CONSUMER_GROUP_DLQ = "dlq-consumer-group";
}


