2 commits

Author	SHA1	Message	Date
Nia Weiss	7734bcd53c	change ID allocation to return a structured error on offset desync ... This is used to handle a possible case where a kafka partition is moved to another ingester while a previous ingester is still processing it, causing 2 ingesters to process it at the same time. This allows a duplicate ingester to skip past messages which have already been ingested.	2021-04-06 10:39:22 -04:00
Nia Weiss	7ea2e4b7e3	add ID auto-generation on the coordinator	2020-12-03 13:04:14 -05:00