consume_callback_queue_callback

@brief Consume multiple messages from queue with callback

@sa rd_kafka_consume_callback()

extern (C) nothrow @nogc

alias consume_callback_queue_callback = void function

(

rd_kafka_message_t* rkmessage

,

void* opaque

)

nothrow @nogc

Meta

Source

See Implementation

deimos rdkafka aliases

enums

functions

manifest constants

structs

variables

RD_KAFKA_PARTITION_UA