Module rdkafka::consumer::stream_consumer
[−]
[src]
Stream-based consumer implementation.
Structs
| StreamConsumer |
A Consumer with an associated polling thread. This consumer doesn't need to
be polled and it will return all consumed messages as a |