DBZ-7098 Enable tombstones for sinks capable of handling them

debezium · Jan 5, 2024 · 6954707 · 6954707
1 parent 934086c
commit 6954707
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 10 deletions.
diff --git a/...rver-rabbitmq/src/main/java/io/debezium/server/rabbitmq/RabbitMqStreamChangeConsumer.java b/...rver-rabbitmq/src/main/java/io/debezium/server/rabbitmq/RabbitMqStreamChangeConsumer.java
@@ -171,11 +171,6 @@ public void handleBatch(List<ChangeEvent<Object, Object>> records, RecordCommitt
         committer.markBatchFinished();
     }
 
-    @Override
-    public boolean supportsTombstoneEvents() {
-        return false;
-    }
-
     private Map<String, Object> convertRabbitMqHeaders(ChangeEvent<Object, Object> record) {
         List<Header<Object>> headers = record.headers();
         Map<String, Object> rabbitMqHeaders = new HashMap<>();

diff --git a/...abbitmq/src/main/java/io/debezium/server/rabbitmq/RabbitMqStreamNativeChangeConsumer.java b/...abbitmq/src/main/java/io/debezium/server/rabbitmq/RabbitMqStreamNativeChangeConsumer.java
@@ -144,11 +144,6 @@ public void handleBatch(List<ChangeEvent<Object, Object>> records, RecordCommitt
         committer.markBatchFinished();
     }
 
-    @Override
-    public boolean supportsTombstoneEvents() {
-        return false;
-    }
-
     private Map<String, Object> convertRabbitMqHeaders(ChangeEvent<Object, Object> record) {
         List<Header<Object>> headers = record.headers();
         Map<String, Object> rabbitMqHeaders = new HashMap<>();