KafkaConsumer.consume

class KafkaConsumer

nothrow @nogc

consume

(

ref Message msg

,

int timeout_ms = 10

)

Parameters

msg Message: message to fill. Use msg.err to check errors.
timeout_ms int: time to to wait if no incomming msgs in queue.

Meta

Source

See Implementation

rdkafkad handler kafka_consumer KafkaConsumer constructors

this

functions