laserdisc-io/tamer

Offset update should guarantee all elements have been pushed

Closed this issue · 2 comments

sirocchj commented

It currently could be updated before the last batch (in queue) has been published to Kafka. Likely solvable with a semaphore

gurghet commented

This is kinda solved by convention. We force it like this or the fiber dies.

  • 👍1
sirocchj commented

Fixed by #520