DBZ-8035 Align core changes

debezium · Aug 20, 2024 · 2f121df · 2f121df
1 parent 443f4f1
commit 2f121df
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/java/io/debezium/connector/cassandra/CassandraConnectorContext.java b/core/src/main/java/io/debezium/connector/cassandra/CassandraConnectorContext.java
@@ -29,7 +29,7 @@ public class CassandraConnectorContext extends CdcSourceTaskContext {
     private final Set<String> erroneousCommitLogs = ConcurrentHashMap.newKeySet();
 
     public CassandraConnectorContext(CassandraConnectorConfig config) {
-        super(config.getContextName(), config.getLogicalName(), config.getCustomMetricTags(), Collections::emptySet);
+        super(config, config.getCustomMetricTags(), Collections::emptySet);
         this.config = config;
         prepareQueues();
     }
@@ -38,7 +38,7 @@ public CassandraConnectorContext(CassandraConnectorConfig config,
                                      SchemaLoader schemaLoader,
                                      SchemaChangeListenerProvider schemaChangeListenerProvider,
                                      OffsetWriter offsetWriter) {
-        super(config.getContextName(), config.getLogicalName(), config.getCustomMetricTags(), Collections::emptySet);
+        super(config, config.getCustomMetricTags(), Collections::emptySet);
         this.config = config;
         this.offsetWriter = offsetWriter;