Events will trigger 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 events, provide -1.
Events:
- delivery report callbacks (if an DeliveryCb is configured) producer
- event callbacks (if an EventCb is configured) [producer & consumer]
Note: An application should make sure to call poll() at regular
intervals to serve any queued callbacks waiting to be called.
Warning: This method MUST NOT be used with the KafkaConsumer,
use its consume() instead.
Polls the provided kafka handle for events.
Events will trigger 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 events, provide -1.
Events: - delivery report callbacks (if an DeliveryCb is configured) producer - event callbacks (if an EventCb is configured) [producer & consumer]
Note: An application should make sure to call poll() at regular intervals to serve any queued callbacks waiting to be called.
Warning: This method MUST NOT be used with the KafkaConsumer, use its consume() instead.
the number of events served.