Crate stream_consumer_task

Crate stream_consumer_task 

Source

Structs§

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

Traits§

Stream
A stream.