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