pub async fn handle_event( __arg0: Json<Event>, tx: Sender<Event>, ) -> Result<(), StatusCode>
Handles incoming events from the producer.