librdkafka ~master (2019-06-10T17:47:26Z)

rd_kafka_consume_batch_queue

deimos rdkafka

@brief Consume batch of messages from queue

@sa rd_kafka_consume_batch()

extern (C) nothrow @nogc
ssize_t
rd_kafka_consume_batch_queue
(
rd_kafka_queue_t* rkqu
,
int timeout_ms
,
rd_kafka_message_t** rkmessages
,
size_t rkmessages_size
)

Meta

Source

See Implementation

deimos rdkafka aliasesenumsfunctionsmanifest constantsstructsvariables

Page generated by adrdox