diff --git a/src/v/cluster/persisted_stm.cc b/src/v/cluster/persisted_stm.cc index 1759e8123026..b20930b38852 100644 --- a/src/v/cluster/persisted_stm.cc +++ b/src/v/cluster/persisted_stm.cc @@ -12,6 +12,7 @@ #include "cluster/logger.h" #include "raft/consensus.h" #include "raft/errc.h" +#include "raft/offset_monitor.h" #include "raft/types.h" #include "storage/record_batch_builder.h" #include "storage/snapshot.h" @@ -229,6 +230,8 @@ ss::future persisted_stm::do_sync( co_return false; } catch (const ss::condition_variable_timed_out&) { co_return false; + } catch (const raft::offset_monitor::wait_aborted&) { + co_return false; } catch (...) { vlog( clusterlog.error,