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

handle concurrent writes to lake #16

Open mccanne opened 2 years ago

mccanne commented 2 years ago

zinger sync from should handle multiple processes writing to a Zed pool and ensure consistency of the computed kafka offsets. We need an option to the Zed lake load endpoint where we can specify a commitID that must be at HEAD in order for the load to complete. This is easy to add given the current model for the constraint check in the lake load logic.