This is an automated email from the ASF dual-hosted git repository. xiangying pushed a commit to branch 2.10.5-fix in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d5b2eb470eb006fd3fb9e27f6e1e3163ff65405c Author: xiangying <[email protected]> AuthorDate: Tue Jul 18 20:07:51 2023 +0800 [fix][build]Fix compatibility issue cause by #20819 --- .../org/apache/pulsar/client/impl/BatchMessageKeyBasedContainer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageKeyBasedContainer.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageKeyBasedContainer.java index 272f2dd54a0..9fdd44715f6 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageKeyBasedContainer.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageKeyBasedContainer.java @@ -68,7 +68,7 @@ class BatchMessageKeyBasedContainer extends AbstractBatchMessageContainer { part.compressor = compressor; part.maxBatchSize = maxBatchSize; part.topicName = topicName; - part.producerName = producerName; + part.producerName = producer.getProducerName(); batches.putIfAbsent(key, part); if (msg.getMessageBuilder().hasTxnidMostBits() && currentTxnidMostBits == -1) { @@ -104,7 +104,7 @@ class BatchMessageKeyBasedContainer extends AbstractBatchMessageContainer { // Need to protect ourselves from any exception being thrown in the future handler from the application batches.forEach((k, v) -> v.firstCallback.sendComplete(ex)); } catch (Throwable t) { - log.warn("[{}] [{}] Got exception while completing the callback", topicName, producerName, t); + log.warn("[{}] [{}] Got exception while completing the callback", topicName, producer.getProducerName(), t); } batches.forEach((k, v) -> ReferenceCountUtil.safeRelease(v.batchedMessageMetadataAndPayload)); clear();
