[fix][build]Fix compatibility issue cause by #20819 (#20834)

apache · Jul 19, 2023 · 1eb5eb3 · 1eb5eb3
1 parent 4a894af
commit 1eb5eb3
Showing 1 changed file with 2 additions and 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
@@ -68,7 +68,7 @@ public boolean add(MessageImpl<?> msg, SendCallback callback) {
             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 @@ public void discard(Exception ex) {
             // 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();