diff --git a/src/v/raft/recovery_stm.cc b/src/v/raft/recovery_stm.cc index 1a098638b04ce..b95e656528602 100644 --- a/src/v/raft/recovery_stm.cc +++ b/src/v/raft/recovery_stm.cc @@ -48,8 +48,9 @@ recovery_stm::recovery_stm( , _ctxlog( raftlog, ssx::sformat( - "[follower: {}] [group_id:{}, {}]", + "[follower: {}, term: {}] [group_id:{}, {}]", _node_id, + _term, _ptr->group(), _ptr->ntp())) , _memory_quota(quota) {} diff --git a/src/v/raft/types.cc b/src/v/raft/types.cc index 9adfb2722b5e5..32eea4283dd6d 100644 --- a/src/v/raft/types.cc +++ b/src/v/raft/types.cc @@ -142,6 +142,7 @@ void follower_index_metadata::reset() { last_successful_received_seq = follower_req_seq{0}; inflight_append_request_count = 0; last_sent_protocol_meta.reset(); + follower_state_change.broadcast(); } std::ostream& operator<<(std::ostream& o, const vnode& id) {