Module rdkafka::consumer::stream_consumer

Stream-based consumer implementation.

Structs

MessageStream

A Stream of Kafka messages. It can be used to receive messages as they are received.

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 Stream. Due to the asynchronous nature of the stream, some messages might be consumed by the consumer without being processed on the other end of the stream. If auto commit is used, it might cause message loss after consumer restart. Manual offset commit should be used instead.