diff --git a/src/main/java/io/debezium/connector/vitess/VitessConnectorTask.java b/src/main/java/io/debezium/connector/vitess/VitessConnectorTask.java index 28900359..2b7004d6 100644 --- a/src/main/java/io/debezium/connector/vitess/VitessConnectorTask.java +++ b/src/main/java/io/debezium/connector/vitess/VitessConnectorTask.java @@ -34,9 +34,11 @@ import io.debezium.pipeline.metrics.DefaultChangeEventSourceMetricsFactory; import io.debezium.pipeline.notification.NotificationService; import io.debezium.pipeline.spi.Offsets; +import io.debezium.processors.PostProcessorRegistryServiceProvider; 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; @@ -242,4 +244,11 @@ protected void doStop() { protected Iterable getAllConfigurationFields() { return VitessConnectorConfig.ALL_FIELDS; } + + // Remove when support for SPI snapshotter will be implemented with DBZ-7307 + @Override + protected void registerServiceProviders(ServiceRegistry serviceRegistry) { + + serviceRegistry.registerServiceProvider(new PostProcessorRegistryServiceProvider()); + } }