rd_kafka_queue_poll_callback method

int rd_kafka_queue_poll_callback(Pointer<rd_kafka_queue_t> rkqu, int timeout_ms)

@brief Poll a queue for events served through callbacks for max \p timeout_ms.

@returns the number of events served.

@remark This API must only be used for queues with callbacks registered for all expected event types. E.g., not a message queue.

@remark Also see rd_kafka_conf_set_background_event_cb() for triggering event callbacks from a librdkafka-managed background thread.

@sa rd_kafka_conf_set_background_event_cb()

Implementation

int rd_kafka_queue_poll_callback(
  ffi.Pointer<rd_kafka_queue_t> rkqu,
  int timeout_ms,
) {
  return _rd_kafka_queue_poll_callback(rkqu, timeout_ms);
}