From da2262395dda54463ddd1bd4fe41f071ed30e20a Mon Sep 17 00:00:00 2001 From: Alexander Zavorotynskiy Date: Mon, 8 Aug 2022 14:41:03 +0200 Subject: [PATCH] fix(backend): fixed failover mechanism --- ee/backend/pkg/failover/failover.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/ee/backend/pkg/failover/failover.go b/ee/backend/pkg/failover/failover.go index acee0dbbe..d69a2c86a 100644 --- a/ee/backend/pkg/failover/failover.go +++ b/ee/backend/pkg/failover/failover.go @@ -60,10 +60,12 @@ func NewSessionFinder(cfg *config.Config, stg *storage.Storage) (SessionFinder, []string{ cfg.TopicFailover, }, - func(sessionID uint64, msg messages.Message, meta *types.Meta) { - switch m := msg.(type) { - case *messages.SessionSearch: - finder.findSession(sessionID, m.Timestamp, m.Partition) + func(sessionID uint64, iter messages.Iterator, meta *types.Meta) { + for iter.Next() { + if iter.Type() == 127 { + m := iter.Message().Decode().(*messages.SessionSearch) + finder.findSession(sessionID, m.Timestamp, m.Partition) + } } }, true,