diff --git a/pulsar-client-cpp/lib/NegativeAcksTracker.cc b/pulsar-client-cpp/lib/NegativeAcksTracker.cc index 492e379459393..202c5e48825aa 100644 --- a/pulsar-client-cpp/lib/NegativeAcksTracker.cc +++ b/pulsar-client-cpp/lib/NegativeAcksTracker.cc @@ -74,7 +74,9 @@ void NegativeAcksTracker::handleTimer(const boost::system::error_code &ec) { } } - consumer_.redeliverMessages(messagesToRedeliver); + if (!messagesToRedeliver.empty()) { + consumer_.redeliverMessages(messagesToRedeliver); + } scheduleTimer(); }