pub(crate) async fn ack_messages(pending: &mut Vec<Message>, channel: u8)Expand description
Acks messages whose samples are all inside closed, synced Parquet files.
Drains pending. A failed ack is counted and logged, not retried; JetStream
redelivers that message after ack_wait, so its samples are written a second time
into a later file.
ยงArguments
pending- Messages to ack; empty on return.channel- Channel number, for the log message.