Do not use BatchedMessageIdImpl as the message id in producer callback

Fix the regression introduced in apache#153 ---- 9.006, 8.860, 9.113
BewareMyPower · Oct 27, 2024 · 7a1e590 · 7a1e590
1 parent 42ecdac
commit 7a1e590
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/MessageAndCallbackBatch.cc b/lib/MessageAndCallbackBatch.cc
@@ -92,7 +92,7 @@ static void completeSendCallbacks(const std::vector<SendCallback>& callbacks, Re
                                   const MessageId& id) {
     int32_t numOfMessages = static_cast<int32_t>(callbacks.size());
     for (int32_t i = 0; i < numOfMessages; i++) {
-        callbacks[i](result, MessageIdBuilder::from(id).batchIndex(i).batchSize(numOfMessages).build());
+        callbacks[i](result, MessageIdBuilder::from(id).batchIndex(i).build());
     }
 }