Type Definition sea_streamer_kafka::KafkaMessageStream
source · pub type KafkaMessageStream<'a> = StreamMap<RawMessageStream<'a>, fn(_: Result<RawMessage<'a>, KafkaErr>) -> KafkaResult<KafkaMessage<'a>>>;Expand description
Concrete type of Stream that will yield the next messages.