(kafka) branch trunk updated: MINOR: Reduce allocations constructing RecordHeaders (#22641)

[mimaison]

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

mimaison pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 6c3b63b825a MINOR: Reduce allocations constructing RecordHeaders 
(#22641)
6c3b63b825a is described below

commit 6c3b63b825a594fb5e67f5f1ae46275f75ec8a9c
Author: winfriedgerlach <158032591+winfriedgerl...@users.noreply.github.com>
AuthorDate: Fri Jun 26 14:16:19 2026 +0200

    MINOR: Reduce allocations constructing RecordHeaders (#22641)
    
    
    Reviewers: Mickael Maison <mickael.mai...@gmail.com>
---
 .../org/apache/kafka/common/header/internals/RecordHeaders.java  | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeaders.java
 
b/clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeaders.java
index 543a23ceea3..a9f49fd04a8 100644
--- 
a/clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeaders.java
+++ 
b/clients/src/main/java/org/apache/kafka/common/header/internals/RecordHeaders.java
@@ -22,7 +22,6 @@ import org.apache.kafka.common.record.internal.Record;
 import org.apache.kafka.common.utils.internals.AbstractIterator;
 
 import java.util.ArrayList;
-import java.util.Arrays;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Objects;
@@ -37,7 +36,13 @@ public class RecordHeaders implements Headers {
     }
 
     public RecordHeaders(Header[] headers) {
-        this(headers == null ? null : Arrays.asList(headers));
+        this.headers = new ArrayList<>();
+        if (headers != null) {
+            for (Header header : headers) {
+                Objects.requireNonNull(header, "Header cannot be null.");
+                this.headers.add(header);
+            }
+        }
     }
 
     public RecordHeaders(Iterable<Header> headers) {