Do not log useless Error deleting cursor errors

streamnative · Jun 25, 2023 · ed1ad01 · ed1ad01
1 parent a6eb7a6
commit ed1ad01
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaTopicConsumerManager.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaTopicConsumerManager.java
@@ -124,6 +124,11 @@ public void deleteCursorComplete(Object ctx) {
 
                 @Override
                 public void deleteCursorFailed(ManagedLedgerException exception, Object ctx) {
+                    if (exception instanceof ManagedLedgerException.CursorNotFoundException) {
+                        log.debug("[{}] Cursor already deleted {} for topic {} for reason: {} - {}.",
+                            requestHandler.ctx.channel(), cursor.getName(), topic.getName(), reason,
+                            String.valueOf(exception));
+                    }
                     log.warn("[{}] Error deleting cursor {} for topic {} for reason: {}.",
                         requestHandler.ctx.channel(), cursor.getName(), topic.getName(), reason, exception);
                 }