This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-3.2 by this push:
new d43a640f1c9 [improve][broker] Clear thread local BrokerEntryMetadata
instance before reuse (#22752)
d43a640f1c9 is described below
commit d43a640f1c9860662bba19f70a079d1db7066de5
Author: Lari Hotari <[email protected]>
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) {
