Skip to content

Commit

Permalink
DBZ-7308 Remove connector specific SnapshotLockProvider and Snapshott…
Browse files Browse the repository at this point in the history
…erServiceProvider
  • Loading branch information
mfvitale authored and jpechane committed Mar 25, 2024
1 parent 44a057b commit 70afb5d
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 62 deletions.
10 changes: 0 additions & 10 deletions src/main/java/io/debezium/connector/db2/Db2ConnectorTask.java
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,6 @@
import io.debezium.config.Field;
import io.debezium.connector.base.ChangeEventQueue;
import io.debezium.connector.common.BaseSourceTask;
import io.debezium.connector.db2.snapshot.Db2SnapshotLockProvider;
import io.debezium.connector.db2.snapshot.Db2SnapshotterServiceProvider;
import io.debezium.document.DocumentReader;
import io.debezium.jdbc.DefaultMainConnectionProvidingConnectionFactory;
import io.debezium.jdbc.MainConnectionProvidingConnectionFactory;
Expand All @@ -37,7 +35,6 @@
import io.debezium.relational.TableId;
import io.debezium.schema.SchemaFactory;
import io.debezium.schema.SchemaNameAdjuster;
import io.debezium.service.spi.ServiceRegistry;
import io.debezium.snapshot.SnapshotterService;
import io.debezium.spi.topic.TopicNamingStrategy;
import io.debezium.util.Clock;
Expand Down Expand Up @@ -230,11 +227,4 @@ private static Configuration applyFetchSizeToJdbcConfig(Configuration config) {
return config;
}

@Override
protected void registerServiceProviders(ServiceRegistry serviceRegistry) {

super.registerServiceProviders(serviceRegistry);
serviceRegistry.registerServiceProvider(new Db2SnapshotLockProvider());
serviceRegistry.registerServiceProvider(new Db2SnapshotterServiceProvider());
}
}

This file was deleted.

This file was deleted.

0 comments on commit 70afb5d

Please sign in to comment.