diff --git a/pulsar-client-cpp/lib/ClientConnection.cc b/pulsar-client-cpp/lib/ClientConnection.cc index 47ab4f79bd0dc..8784cc98cb546 100644 --- a/pulsar-client-cpp/lib/ClientConnection.cc +++ b/pulsar-client-cpp/lib/ClientConnection.cc @@ -1582,7 +1582,7 @@ Future ClientConnection::newGetLastMessageId(uint64_t consume pendingGetLastMessageIdRequests_.insert(std::make_pair(requestId, promise)); lock.unlock(); - sendCommand(Commands::newGetLastMessageId(consumerId, requestId)); + sendRequestWithId(Commands::newGetLastMessageId(consumerId, requestId), requestId); return promise.getFuture(); }