[][src]Module rdkafka::consumer::stream_consumer

Stream-based consumer implementation.

Structs

MessageStream

A Kafka consumer implementing Stream.

StreamConsumer

A Kafka Consumer providing a futures::Stream interface.