Expand description

High-level consumers with a Stream interface.

Structs

A stream of messages from a StreamConsumer.

A high-level consumer with a Stream interface.

A message queue for a single partition of a StreamConsumer.