rd_kafka_consume_callback_queue

@brief Consume multiple messages from queue with callback

@sa rd_kafka_consume_callback()

alias consume_callback_queue_callback = void function(rd_kafka_message_t* rkmessage, void* opaque) nothrow @(nogc)
int rd_kafka_consume_callback_queue(rd_kafka_queue_t* rkqu, int timeout_ms, consume_callback_queue_callback consume_cb, void* opaque)
extern (C) nothrow @nogc
int
rd_kafka_consume_callback_queue
(
rd_kafka_queue_t* rkqu
,
int timeout_ms
,
consume_callback_queue_callback consume_cb
,
void* opaque
)

Meta

Source

See Implementation

deimos rdkafka aliases

enums

functions

manifest constants

structs

variables

RD_KAFKA_PARTITION_UA