@@ -433,7 +433,7 @@ public void readEntriesFailed(ManagedLedgerException exception, Object ctx) {
433433 long waitTimeMillis = readFailureBackoff .next ();
434434
435435 if (exception instanceof CursorAlreadyClosedException ) {
436- log .error ("[{}] Error reading entries because replicator is"
436+ log .warn ("[{}] Error reading entries because replicator is"
437437 + " already deleted and cursor is already closed {}, ({})" ,
438438 replicatorId , ctx , exception .getMessage (), exception );
439439 // replicator is already deleted and cursor is already closed so, producer should also be stopped
@@ -553,7 +553,7 @@ public void deleteFailed(ManagedLedgerException exception, Object ctx) {
553553 log .error ("[{}] Failed to delete message at {}: {}" , replicatorId , ctx ,
554554 exception .getMessage (), exception );
555555 if (exception instanceof CursorAlreadyClosedException ) {
556- log .error ("[{}] Asynchronous ack failure because replicator is already deleted and cursor is already"
556+ log .warn ("[{}] Asynchronous ack failure because replicator is already deleted and cursor is already"
557557 + " closed {}, ({})" , replicatorId , ctx , exception .getMessage (), exception );
558558 // replicator is already deleted and cursor is already closed so, producer should also be stopped
559559 closeProducerAsync ();
0 commit comments