Skip to main content

ack_consumer

allsource_core::infrastructure::web::api

Function ack_consumer 

Source 
pub async fn ack_consumer(
    __arg0: State<Arc<EventStore>>,
    __arg1: Path<String>,
    __arg2: Json<AckRequest>,
) -> Result<Json<Value>>
Expand description

POST /api/v1/consumers/{consumer_id}/ack — Acknowledge processed events