rd_kafka_consumer_close_queue method

Pointer<rd_kafka_error_t> rd_kafka_consumer_close_queue(Pointer<rd_kafka_t> rk, Pointer<rd_kafka_queue_t> rkqu)

@brief Asynchronously close the consumer.

Performs the same actions as rd_kafka_consumer_close() but in a background thread.

Rebalance events/callbacks (etc) will be forwarded to the application-provided \p rkqu. The application must poll/serve this queue until rd_kafka_consumer_closed() returns true.

@remark Depending on consumer group join state there may or may not be rebalance events emitted on \p rkqu.

@returns an error object if the consumer close failed, else NULL.

@sa rd_kafka_consumer_closed()

Implementation

ffi.Pointer<rd_kafka_error_t> rd_kafka_consumer_close_queue(
  ffi.Pointer<rd_kafka_t> rk,
  ffi.Pointer<rd_kafka_queue_t> rkqu,
) {
  return _rd_kafka_consumer_close_queue(rk, rkqu);
}