From 9312ccc2dc7e6b155abd4898436d52b096334be5 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Tue, 15 Dec 2020 14:52:38 +0000 Subject: [PATCH] Tweak toOffset --- syncapi/internal/keychange.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/syncapi/internal/keychange.go b/syncapi/internal/keychange.go index cf9cb1f07..6af48a9ce 100644 --- a/syncapi/internal/keychange.go +++ b/syncapi/internal/keychange.go @@ -79,7 +79,7 @@ func DeviceListCatchup( } var toOffset int64 toOffset = sarama.OffsetNewest - if toLog := to.DeviceListPosition; toLog.Offset > 0 { + if toLog := to.DeviceListPosition; toLog.Partition == partition && toLog.Offset > 0 { toOffset = toLog.Offset } var queryRes api.QueryKeyChangesResponse