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

…ore reuse (#22752) (cherry picked from commit adad1fb)
apache · Nov 23, 2024 · f4fa5b9 · f4fa5b9
1 parent 2cacf06
commit f4fa5b9
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
@@ -1713,6 +1713,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) {