We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 42bcc58 commit 8ad42f3Copy full SHA for 8ad42f3
lib/ProducerImpl.cc
@@ -879,7 +879,7 @@ bool ProducerImpl::removeCorruptMessage(uint64_t sequenceId) {
879
return true;
880
}
881
882
- std::unique_ptr<OpSendMsg> op{std::move(pendingMessagesQueue_.front().release())};
+ std::unique_ptr<OpSendMsg> op{pendingMessagesQueue_.front().release()};
883
uint64_t expectedSequenceId = op->sendArgs->sequenceId;
884
if (sequenceId > expectedSequenceId) {
885
LOG_WARN(getName() << "Got ack failure for msg " << sequenceId //
0 commit comments