fifo: add additional offset-related error checking

brimdata / zync

Kafka connector to sync Zed lakes to and from Kafka topics

BSD 3-Clause "New" or "Revised" License

18 stars 3 forks source link

fifo: add additional offset-related error checking #105

Closed nwt closed 1 year ago

nwt commented 1 year ago

A user encountered an instance of "zync from-kafka" creating records with duplicate Kafka offsets. Why this happened is unclear so add a couple of additional error checks to guard against a reccurrence.