diff --git a/rd-cpp/src/rd_framework_cpp/src/main/wire/SocketWire.cpp b/rd-cpp/src/rd_framework_cpp/src/main/wire/SocketWire.cpp index be594ed44..bc7c91c40 100644 --- a/rd-cpp/src/rd_framework_cpp/src/main/wire/SocketWire.cpp +++ b/rd-cpp/src/rd_framework_cpp/src/main/wire/SocketWire.cpp @@ -329,7 +329,8 @@ int32_t SocketWire::Base::read_package() const send_ack(seqn); if (seqn <= max_received_seqn && seqn != 1) { - return true; + logger->trace("{}: duplicate package seqn={} (max_received_seqn={}), skipping", this->id, seqn, max_received_seqn); + return 0; } max_received_seqn = seqn;