remove debug logs in stream which were used during development

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
eclipse-ditto · Aug 26, 2021 · b8f72b5 · b8f72b5
1 parent 0008ecf
commit b8f72b5
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 5 deletions.
diff --git a/...ava/org/eclipse/ditto/connectivity/service/messaging/kafka/AtLeastOnceConsumerStream.java b/...ava/org/eclipse/ditto/connectivity/service/messaging/kafka/AtLeastOnceConsumerStream.java
@@ -89,7 +89,6 @@ public CompletionStage<Done> start() throws IllegalStateException {
                 .runWith(unexpectedMessageSink(), materializer);
     }
 
-
     @Override
     public void stop() {
         if (consumerControl != null) {
@@ -110,8 +109,6 @@ public void stop() {
     private Sink<KafkaAcknowledgableMessage, NotUsed> committerSink() {
         return Flow.of(KafkaAcknowledgableMessage.class)
                 .mapAsync(1, KafkaAcknowledgableMessage::getAcknowledgementFuture)
-                .log("yannic test")
-                .withAttributes(Attributes.logLevels(Attributes.logLevelInfo(), Attributes.logLevelInfo(), Attributes.logLevelInfo()))
                 .to(Committer.sink(committerSettings));
     }
 

diff --git a/...va/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaAcknowledgableMessage.java b/...va/org/eclipse/ditto/connectivity/service/messaging/kafka/KafkaAcknowledgableMessage.java
@@ -28,8 +28,7 @@ final class KafkaAcknowledgableMessage {
             final ConsumerMessage.CommittableOffset committableOffset) {
         this.acknowledgementFuture = new CompletableFuture<>();
         this.acknowledgeableMessage = AcknowledgeableMessage.of(message,
-                () ->
-                        acknowledgementFuture.complete(committableOffset),
+                () -> acknowledgementFuture.complete(committableOffset),
                 shouldRedeliver -> {
                     if (shouldRedeliver) {
                         acknowledgementFuture.completeExceptionally(MessageRejectedException.getInstance());