DBZ-812 CDC tables poll interval derived from poll.interval.ms
This commit is contained in:
parent
ed9706657c
commit
b6b85f8d58
@ -64,7 +64,7 @@ public SqlServerStreamingChangeEventSource(SqlServerConnectorConfig connectorCon
|
||||
this.clock = clock;
|
||||
this.schema = schema;
|
||||
this.offsetContext = offsetContext;
|
||||
this.pollInterval = Duration.ofSeconds(1);
|
||||
this.pollInterval = connectorConfig.getPollInterval();
|
||||
}
|
||||
|
||||
@Override
|
||||
|
@ -6,13 +6,11 @@
|
||||
package io.debezium.connector.sqlserver;
|
||||
|
||||
import java.sql.SQLException;
|
||||
import java.util.List;
|
||||
|
||||
import org.apache.kafka.connect.data.Schema;
|
||||
import org.apache.kafka.connect.data.SchemaBuilder;
|
||||
import org.apache.kafka.connect.data.Struct;
|
||||
import org.fest.assertions.Assertions;
|
||||
import org.fest.util.Collections;
|
||||
import org.junit.After;
|
||||
import org.junit.Before;
|
||||
import org.junit.Test;
|
||||
@ -20,7 +18,6 @@
|
||||
import io.debezium.config.Configuration;
|
||||
import io.debezium.connector.sqlserver.SqlServerConnectorConfig.SnapshotMode;
|
||||
import io.debezium.connector.sqlserver.util.TestHelper;
|
||||
import io.debezium.data.SchemaAndValueField;
|
||||
import io.debezium.embedded.AbstractConnectorTest;
|
||||
import io.debezium.util.Testing;
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user