diff --git a/cluster/informer.go b/cluster/informer.go index 4118aa37..ce364313 100644 --- a/cluster/informer.go +++ b/cluster/informer.go @@ -7,7 +7,7 @@ import ( "google.golang.org/protobuf/types/known/anypb" "log/slog" "math/rand" - "reflect" + "maps" "time" "github.com/asynkron/gofun/set" @@ -211,7 +211,7 @@ func (inf *Informer) GetMemberStateDelta(targetMemberID string) *MemberStateDelt } } - hasState := reflect.DeepEqual(inf.committedOffsets, pendingOffsets) + hasState := maps.Equal(inf.committedOffsets, pendingOffsets) memberState := &MemberStateDelta{ TargetMemberID: targetMemberID, HasState: hasState,