From aecd318dda33fd12efa35bf4318f14e9c6e26cc2 Mon Sep 17 00:00:00 2001 From: Xiaoyu Hou Date: Fri, 26 Aug 2022 18:54:31 +0800 Subject: [PATCH] Fix sendMessage params list not match --- .../apache/pulsar/client/impl/BatchMessageContainerImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java index a5e77a5bcdd68..74bd86a2b2caa 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java @@ -220,7 +220,7 @@ public OpSendMsg createOpSendMsg() throws IOException { messageMetadata.copyFrom(messages.get(0).getMessageBuilder()); ByteBuf encryptedPayload = producer.encryptMessage(messageMetadata, getCompressedBatchMetadataAndPayload()); ByteBufPair cmd = producer.sendMessage(producer.producerId, messageMetadata.getSequenceId(), - 1, messageMetadata, encryptedPayload); + 1, messages.get(0).getMessageId(), messageMetadata, encryptedPayload); final OpSendMsg op; // Shouldn't call create(MessageImpl msg, ByteBufPair cmd, long sequenceId, SendCallback callback),