ensure consumed offset doesn't go past end of topic... this was causing an offset out of range error.
This commit is contained in:
Родитель
9fc7b5c4b0
Коммит
c26ac28a6c
|
@ -514,7 +514,7 @@ namespace Kafka.Client.ZooKeeperIntegration.Listeners
|
|||
leader,
|
||||
partitionId,
|
||||
queue,
|
||||
offset,
|
||||
offset - 1,
|
||||
offset,
|
||||
offset,
|
||||
this.config.FetchSize,
|
||||
|
|
Загрузка…
Ссылка в новой задаче