disable cdc

raft-tech · Sep 30, 2024 · b7aac2b · b7aac2b
1 parent 8d24e41
commit b7aac2b
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/server/src/main/java/com/arcadedb/server/kafka/KafkaEventListener.java b/server/src/main/java/com/arcadedb/server/kafka/KafkaEventListener.java
@@ -38,27 +38,27 @@ public KafkaEventListener(final KafkaClient client, final String dbName, String
          */
         this.databaseUsername = databaseUsername == null ? "admin" : databaseUsername;
 
-        this.client.createTopicIfNotExists(this.client.getTopicNameForDatabase(this.databaseName, this.databaseUsername));
+    //    this.client.createTopicIfNotExists(this.client.getTopicNameForDatabase(this.databaseName, this.databaseUsername));
     }
 
     @Override
     public void onAfterCreate(Record record) {
-        Message message = KafkaRecordUtil.createMessage(RecordEvents.AFTER_RECORD_CREATE, record);
+    //    Message message = KafkaRecordUtil.createMessage(RecordEvents.AFTER_RECORD_CREATE, record);
 
-        this.client.sendMessage(this.databaseName, this.databaseUsername, message);
+    //    this.client.sendMessage(this.databaseName, this.databaseUsername, message);
     }
 
     @Override
     public void onAfterDelete(Record record) {
-        Message message = KafkaRecordUtil.createMessage(RecordEvents.AFTER_RECORD_DELETE, record);
+    //    Message message = KafkaRecordUtil.createMessage(RecordEvents.AFTER_RECORD_DELETE, record);
 
-        this.client.sendMessage(this.databaseName, this.databaseUsername, message);
+    //    this.client.sendMessage(this.databaseName, this.databaseUsername, message);
     }
 
     @Override
     public void onAfterUpdate(Record record) {
-        Message message = KafkaRecordUtil.createMessage(RecordEvents.AFTER_RECORD_UPDATE, record);
+    //    Message message = KafkaRecordUtil.createMessage(RecordEvents.AFTER_RECORD_UPDATE, record);
 
-        this.client.sendMessage(this.databaseName, this.databaseUsername, message);
+    //    this.client.sendMessage(this.databaseName, this.databaseUsername, message);
     }
 }