fix: prefer use Buffer instead of Object for recordHeaders

gravitee-io · Nov 5, 2024 · 1a622fc · 1a622fc
1 parent 987adf1
commit 1a622fc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/gravitee/gateway/reactive/api/message/kafka/KafkaMessage.java b/src/main/java/io/gravitee/gateway/reactive/api/message/kafka/KafkaMessage.java
@@ -26,7 +26,7 @@ public interface KafkaMessage extends Message {
      * Get the Kafka record headers associated to the message.
      * @return the Kafka headers
      */
-    Map<String, Object> recordHeaders();
+    Map<String, Buffer> recordHeaders();
 
     /**
      * Get the Kafka record key associated to the message.