package com.kxs.transfer.api.config;

import lombok.Data;
import lombok.Getter;
import lombok.Setter;
import org.springframework.boot.context.properties.ConfigurationProperties;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * dts数据订阅属性
 *
 * @author ： liukx
 * @time ： 2020/9/22 - 17:03
 */
@Data
@ConfigurationProperties(prefix = "spring.dts")
public class DTSProperties {
    /**
     * 用户名
     */
    private String username;
    /**
     * 密码
     */
    private String password;
    /**
     * 消费组id [dts->数据消费列表->消费组ID]
     */
    private String sid;
    /**
     * 消费组名称[dts->数据消费列表->消费组名称]
     */
    private String groupName;
    /**
     * kafka topic配置 [dts->订阅配置->基本信息->订阅Topic]
     */
    private String kafkaTopic;
    /**
     * kafka 连接地址 [dts->订阅配置->网络->公私网]
     */
    private String brokerUrl;
    /**
     * 启动位点 : 这里表示消费的起点,如果是第一次启动则有效.
     */
    private String initCheckpoint = "1705998423";
    /**
     * 如果在启动时强制使用配置检查点。在检查点重置
     */
    private Boolean isForceUseInitCheckpoint = false;

    /**
     * 需要处理的表名
     */
    private List<String> filterTables;

    /**
     * 需要处理的库名
     */
    private List<String> filterDatabase;

}
