diff --git a/quickwit/quickwit-rest-client/src/rest_client.rs b/quickwit/quickwit-rest-client/src/rest_client.rs index e4b02f27cc6..baf62fe192d 100644 --- a/quickwit/quickwit-rest-client/src/rest_client.rs +++ b/quickwit/quickwit-rest-client/src/rest_client.rs @@ -255,7 +255,7 @@ impl QuickwitClient { index_id: &str, ingest_source: IngestSource, batch_size_limit_opt: Option, - on_ingest_event: Option<&dyn Fn(IngestEvent)>, + on_ingest_event: Option<&(dyn Fn(IngestEvent) + Sync)>, last_block_commit: CommitType, ) -> Result<(), Error> { let ingest_path = format!("{index_id}/ingest");