librdkafka-d ~master (2017-04-27T15:04:37Z)

Consumer.consumeCallback

rdkafkad handler simple_consumer Consumer

Consumes messages from \p queue, calling the provided callback for each consumed messsage.

  1. int consumeCallback(Topic topic, int partition, int timeout_ms, ConsumeCb consume_cb)
  2. int consumeCallback(Queue queue, int timeout_ms, ConsumeCb consume_cb)
    class Consumer
    nothrow @nogc static
    int
    consumeCallback
    (
    Queue queue
    ,
    int timeout_ms
    ,
    ConsumeCb consume_cb
    )

See Also

Consumer::consumeCallback()

Meta

Source

See Implementation

rdkafkad handler simple_consumer Consumer constructorsdestructorsstatic functions

Page generated by adrdox