Fix: Always pass cloudevent (can be null) to ingresshandler

knative-extensions · Aug 27, 2024 · 39fb741 · 39fb741
1 parent e264796
commit 39fb741
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...er/src/main/java/dev/knative/eventing/kafka/broker/receiver/impl/handler/AuthHandler.java b/...er/src/main/java/dev/knative/eventing/kafka/broker/receiver/impl/handler/AuthHandler.java
@@ -49,8 +49,8 @@ public void handle(
             // get CloudEvent from request and pass to ingress handler
             VertxMessageFactory.createReader(requestContext.getRequest())
                     .map(MessageReader::toEvent)
-                    .onSuccess(event -> {
-                        next.handle(requestContext, event, ingressInfo);
+                    .onComplete(event -> {
+                        next.handle(requestContext, event.result(), ingressInfo);
                     });
             return;
         }