fix: access Kafka execution context from KafkaMessageExecutionContext

gravitee-io · Jan 8, 2025 · 45d71d0 · 45d71d0
1 parent 046017b
commit 45d71d0
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...ain/java/io/gravitee/gateway/reactive/api/context/kafka/KafkaMessageExecutionContext.java b/...ain/java/io/gravitee/gateway/reactive/api/context/kafka/KafkaMessageExecutionContext.java
@@ -29,6 +29,12 @@
 public interface KafkaMessageExecutionContext extends NativeMessageExecutionContext {
     String TEMPLATE_ATTRIBUTE_MESSAGE = "message";
 
+    /**
+     * Access the execution context.
+     * @return the execution context.
+     */
+    KafkaExecutionContext executionContext();
+
     /**
      * Get the current request attached to this execution context.
      * @return the request.