Tweak toOffset

This commit is contained in:
Neil Alexander 2020-12-15 14:52:38 +00:00
parent bfed962a13
commit 9312ccc2dc
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944

View file

@ -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