diff --git a/cluster/store/store.go b/cluster/store/store.go index 2372bdab..e65db3dd 100644 --- a/cluster/store/store.go +++ b/cluster/store/store.go @@ -164,6 +164,10 @@ func NewStore(config Config) (Store, error) { } func (s *store) Apply(entry *raft.Log) interface{} { + if entry.Type != raft.LogCommand { + return nil + } + logger := s.logger.WithFields(log.Fields{ "index": entry.Index, "term": entry.Term,