(PECL rdkafka >= 4.0.0, librdkafka >= 0.11.0)
RdKafka::flush — Wait until all outstanding produce requests, et.al, are completed.
Descriptionpublic RdKafka::flush ( integer $timeout_ms
) : integer
timeout_ms
(integer)
Specifies the maximum amount of time (in milliseconds) that the call will block. To wait indefinitely provide -1.
In case of success returns RD_KAFKA_RESP_ERR_NO_ERROR
, in case of timeout RD_KAFKA_RESP_ERR__TIMED_OUT
and if not called on a producer instance RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED
.
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4