DBZ-4321 Add PostProcessor support

debezium · Dec 12, 2023 · 07f6c7a · 07f6c7a
1 parent bbb8805
commit 07f6c7a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/io/debezium/connector/spanner/SpannerConnectorTask.java b/src/main/java/io/debezium/connector/spanner/SpannerConnectorTask.java
@@ -196,6 +196,9 @@ protected SpannerChangeEventSourceCoordinator start(Configuration configuration)
         NotificationService<SpannerPartition, SpannerOffsetContext> notificationService = new NotificationService<>(getNotificationChannels(),
                 connectorConfig, SchemaFactory.get(), dispatcher::enqueueNotification);
 
+        // Service providers
+        registerServiceProviders(connectorConfig.getServiceRegistry());
+
         this.coordinator = new SpannerChangeEventSourceCoordinator(
                 getInitialOffsets(),
                 errorHandler,