@brief Polls the provided kafka handle for events.
Events will cause application provided callbacks to be called.
The \p timeout_ms argument specifies the maximum amount of time
(in milliseconds) that the call will block waiting for events.
For non-blocking calls, provide 0 as \p timeout_ms.
To wait indefinately for an event, provide -1.
@remark An application should make sure to call poll() at regular
intervals to serve any queued callbacks waiting to be called.
Events:
- delivery report callbacks (if dr_cb/dr_msg_cb is configured) producer
- error callbacks (rd_kafka_conf_set_error_cb()) all
- stats callbacks (rd_kafka_conf_set_stats_cb()) all
- throttle callbacks (rd_kafka_conf_set_throttle_cb()) all
@brief Polls the provided kafka handle for events.
Events will cause application provided callbacks to be called.
The \p timeout_ms argument specifies the maximum amount of time (in milliseconds) that the call will block waiting for events. For non-blocking calls, provide 0 as \p timeout_ms. To wait indefinately for an event, provide -1.
@remark An application should make sure to call poll() at regular intervals to serve any queued callbacks waiting to be called.
Events: - delivery report callbacks (if dr_cb/dr_msg_cb is configured) producer - error callbacks (rd_kafka_conf_set_error_cb()) all - stats callbacks (rd_kafka_conf_set_stats_cb()) all - throttle callbacks (rd_kafka_conf_set_throttle_cb()) all
@returns the number of events served.