public ConsumerContext()

in src/main/java/com/aliyun/dts/subscribe/clients/ConsumerContext.java [56:71]

• 16 lines of code
• 1 McCabe index (conditional complexity)

    public ConsumerContext(DBMapper dbMapper, String brokerUrl, String topic, String sid, String userName, String password,
                           String initialCheckpoint, ConsumerContext.ConsumerSubscribeMode subscribeMode, Properties properties,
                           boolean isCheckpointNotExistThrowException) {
        this.properties = properties;
        this.dbMapper = dbMapper;
        this.brokerUrl = brokerUrl;
        this.topic = topic;
        this.sid = sid;
        this.user = userName;
        this.password = password;
        this.initialCheckpoint = initialCheckpoint;
        this.subscribeMode = subscribeMode;
        this.dtsMetrics = new DTSMetrics();
        this.useLocalCheckpointStore = true;
        this.isCheckpointNotExistThrowException = isCheckpointNotExistThrowException;
    }