rd_kafka_commit_queue

@brief Commit offsets on broker for the provided list of partitions.

See rd_kafka_commit for \p offsets semantics.

The result of the offset commit will be posted on the provided \p rkqu queue.

If the application uses one of the poll APIs (rd_kafka_poll(), rd_kafka_consumer_poll(), rd_kafka_queue_poll(), ..) to serve the queue the \p cb callback is required. \p opaque is passed to the callback.

If using the event API the callback is ignored and the offset commit result will be returned as an RD_KAFKA_EVENT_COMMIT event. The \p opaque value will be available with rd_kafka_event_opaque()

If \p rkqu is NULL a temporary queue will be created and the callback will be served by this call.

@sa rd_kafka_commit() @sa rd_kafka_conf_set_offset_commit_cb()

Meta