[improve][broker] Clear thread local BrokerEntryMetadata instance bef…

…ore reuse (apache#22752) (cherry picked from commit 18db799)
datastax · Jun 7, 2024 · 49902fe · 49902fe
1 parent bf9cdeb
commit 49902fe
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -1675,6 +1675,7 @@ public static ByteBuf addBrokerEntryMetadata(ByteBuf headerAndPayload,
         //   |         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) {