diff --git a/contrib/raftexample/raft.go b/contrib/raftexample/raft.go index 9475812c6..439d7f1d6 100644 --- a/contrib/raftexample/raft.go +++ b/contrib/raftexample/raft.go @@ -228,7 +228,7 @@ func (rc *raftNode) serveChannels() { rc.wal.Save(rd.HardState, rd.Entries) rc.raftStorage.Append(rd.Entries) rc.transport.Send(rd.Messages) - if ok := rc.publishEntries(rd.Entries); !ok { + if ok := rc.publishEntries(rd.CommittedEntries); !ok { rc.stop() return }