Adrien Guillo

> What's more, I can't see the consumption progress of indexer in Kafka. What's the reason. In the logs, you should see the indexer publish splits regularly with the associated...

Everything looks good except for the `RequiredFastField("id")` errors. I suspect some docs are missing the `id` field. As far as indexing throughput, it may be the case that the volume...

Not tested yet on our EKS cluster.

Yes, there's a deadlock t_t

I fixed the deadlock. Since we're executing sync code in the rebalance hooks, calling `consumer.recv()` is actually sync and blocking. Running the consumer poll loop in a blocking tokio task...

Tests are not fully passing because we ignore the passed checkpoint. Therefore, they need to be rewritten.

#986 ``` quickwit source reset-checkpoint --index --source ```

As discussed offline with @fulmicoton, we currently don't have a pressing need for this API. We will revisit when necessary.

Reopened. See #1631.

This PR is ready for review. I have introduced two new metastore APIs, which completely clears the checkpoints (keys are removed) - `reset_index_checkpoint(index_id)` - `reset_source_checkpoint(index_id, source_id)` I have introduced two...