consume_callback_queue_callback

@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)
extern (C) nothrow @nogc
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)

Meta

Source

See Implementation

deimos rdkafka aliases

enums

functions

manifest constants

structs

variables

RD_KAFKA_PARTITION_UA