(pulsar) branch master updated: [fix][broker] Avoid per-message metadata parse for disabled debug log in handleSend (#25986)

[lhotari]

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

lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 7148b192471 [fix][broker] Avoid per-message metadata parse for 
disabled debug log in handleSend (#25986)
7148b192471 is described below

commit 7148b19247119f2c5ba1ca2eeace2eca23800c84
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Wed Jun 10 01:05:02 2026 -0700

    [fix][broker] Avoid per-message metadata parse for disabled debug log in 
handleSend (#25986)
---
 .../apache/pulsar/broker/service/ServerCnx.java    | 27 +++++++++++-----------
 1 file changed, 14 insertions(+), 13 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
index 7dff4260d23..dc8490061ab 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
@@ -2662,19 +2662,20 @@ public class ServerCnx extends PulsarHandler implements 
TransportCnx {
     }
 
     private void printSendCommandDebug(CommandSend send, ByteBuf 
headersAndPayload) {
-        headersAndPayload.markReaderIndex();
-        MessageMetadata msgMetadata = 
Commands.parseMessageMetadata(headersAndPayload);
-        headersAndPayload.resetReaderIndex();
-        log.debug()
-                .attr("producerId", send.getProducerId())
-                .attr("sendSequenceId", send.getSequenceId())
-                .attr("producerName", msgMetadata.getProducerName())
-                .attr("metadataSequenceId", msgMetadata.getSequenceId())
-                .attr("readableBytes", headersAndPayload.readableBytes())
-                .attr("partitionKey", msgMetadata.hasPartitionKey() ? 
msgMetadata.getPartitionKey() : null)
-                .attr("orderingKey", msgMetadata.hasOrderingKey() ? 
msgMetadata.getOrderingKey() : null)
-                .attr("uncompressedSize", msgMetadata.getUncompressedSize())
-                .log("Received send message request");
+        log.debug(e -> {
+            headersAndPayload.markReaderIndex();
+            MessageMetadata msgMetadata = 
Commands.parseMessageMetadata(headersAndPayload);
+            headersAndPayload.resetReaderIndex();
+            e.attr("producerId", send.getProducerId())
+                    .attr("sendSequenceId", send.getSequenceId())
+                    .attr("producerName", msgMetadata.getProducerName())
+                    .attr("metadataSequenceId", msgMetadata.getSequenceId())
+                    .attr("readableBytes", headersAndPayload.readableBytes())
+                    .attr("partitionKey", msgMetadata.hasPartitionKey() ? 
msgMetadata.getPartitionKey() : null)
+                    .attr("orderingKey", msgMetadata.hasOrderingKey() ? 
msgMetadata.getOrderingKey() : null)
+                    .attr("uncompressedSize", 
msgMetadata.getUncompressedSize())
+                    .log("Received send message request");
+        });
     }
 
     @Override