package com.moral.constant;

public class KafkaConstants {

    /**
     * 分钟数据主题
     */
    public static final String TOPIC_MINUTE = "test_topic";

    /**
     * 小时数据主题
     */
    public static final String TOPIC_HOUR = "hour";

    /**
     * 消费组
     */
    public static final String GROUP_ID = "test";
}