Type Alias sea_streamer_kafka::KafkaMessageStream

pub type KafkaMessageStream<'a> = Map<MessageStream<'a, DefaultConsumerContext>, fn(_: Result<BorrowedMessage<'a>, KafkaErr>) -> KafkaResult<KafkaMessage<'a>>>;

Concrete type of Stream that will yield the next messages.

Aliased Type

struct KafkaMessageStream<'a> { /* private fields */ }