(iggy) branch non_string_header_key updated: Fix user headers json

[piotr]

This is an automated email from the ASF dual-hosted git repository.

piotr pushed a commit to branch non_string_header_key
in repository https://gitbox.apache.org/repos/asf/iggy.git


The following commit(s) were added to refs/heads/non_string_header_key by this 
push:
     new 623666ed0 Fix user headers json
623666ed0 is described below

commit 623666ed0fadba95540755d98a1b613fcb322839
Author: spetz <piotr.gankiew...@gmail.com>
AuthorDate: Thu Jan 29 20:54:44 2026 +0100

    Fix user headers json
---
 core/common/src/commands/messages/send_messages.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/core/common/src/commands/messages/send_messages.rs 
b/core/common/src/commands/messages/send_messages.rs
index 4da03ad06..c4f2913e3 100644
--- a/core/common/src/commands/messages/send_messages.rs
+++ b/core/common/src/commands/messages/send_messages.rs
@@ -208,7 +208,7 @@ impl Serialize for SendMessages {
                         .into_iter()
                         .map(|(k, v)| HeaderEntry { key: k, value: v })
                         .collect();
-                    map.insert("headers", 
serde_json::to_value(&entries).unwrap());
+                    map.insert("user_headers", 
serde_json::to_value(&entries).unwrap());
                 }
 
                 map
@@ -310,7 +310,7 @@ impl<'de> Deserialize<'de> for SendMessages {
                                     .decode(payload)
                                     .map_err(|_| de::Error::custom("Invalid 
base64 payload"))?;
 
-                                let headers_map = if let Some(headers) = 
msg.get("headers") {
+                                let headers_map = if let Some(headers) = 
msg.get("user_headers") {
                                     if headers.is_null() {
                                         None
                                     } else {