The #95 fixes dupes caused by already process offset within a record batch, however such offsets could come within a several record batches. Since last_offset is cleared once buffer is consumed, we cannot check on that. To fix the bug, we have to keep last_offset in between consumes too, e.g. do not clear it at all
The #95 fixes dupes caused by already process offset within a record batch, however such offsets could come within a several record batches. Since last_offset is cleared once buffer is consumed, we cannot check on that. To fix the bug, we have to keep last_offset in between consumes too, e.g. do not clear it at all