Avoid couting rejected messages as consume failures

* They are already counted as failed acknowledgements Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
eclipse-ditto · Sep 3, 2021 · de950ac · de950ac
1 parent ece8ad3
commit de950ac
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/.../main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java b/.../main/java/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaConsumerActor.java
@@ -156,8 +156,6 @@ private void handleStreamCompletion(@Nullable final Done done, @Nullable final T
                     sourceAddress,
                     "Consumer closed", now);
         } else if (realCause instanceof MessageRejectedException) {
-            final MessageRejectedException cause = (MessageRejectedException) throwable.getCause();
-            inboundMonitor.exception(cause);
             status = ConnectivityStatus.CLOSED;
             self().tell(realCause, ActorRef.noSender());
             statusUpdate = ConnectivityModelFactory.newStatusUpdate(