(pulsar) branch master updated: [improve][broker] Clear thread local BrokerEntryMetadata instance before reuse (#22752)

[technoboy]

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

technoboy 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 adad1fb8420 [improve][broker] Clear thread local BrokerEntryMetadata 
instance before reuse (#22752)
adad1fb8420 is described below

commit adad1fb84200f3e6858cea453a7ce6f13ef93de2
Author: Lari Hotari <lhot...@users.noreply.github.com>
AuthorDate: Wed May 22 05:56:14 2024 +0300

    [improve][broker] Clear thread local BrokerEntryMetadata instance before 
reuse (#22752)
---
 .../src/main/java/org/apache/pulsar/common/protocol/Commands.java        | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java 
b/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java
index 65674af0ae1..8599ec2dd34 100644
--- 
a/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java
+++ 
b/pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java
@@ -1705,6 +1705,7 @@ public class Commands {
         //   |         2 bytes                    |       4 bytes              
|    BROKER_ENTRY_METADATA_SIZE bytes   |
 
         BrokerEntryMetadata brokerEntryMetadata = BROKER_ENTRY_METADATA.get();
+        brokerEntryMetadata.clear();
         for (BrokerEntryMetadataInterceptor interceptor : brokerInterceptors) {
             interceptor.intercept(brokerEntryMetadata);
             if (numberOfMessages >= 0) {