Module rdkafka::consumer [] [src]

Consumer implementations.

Structs

Consumer

A Consumer client.

ConsumerPollingThread

A Consumer with an associated polling thread. This consumer doesn't need to be polled and it will return all consumed messages as a Stream.