Crate stream_consumer_task

Source

Structs§

KafkaStreamConsumerAdapter
An adapter used to make easier Stream implementation of StreamConsumer.
StreamConsumerTask
A task that consumes stream in backgroup.

Traits§

Stream
A stream.