Structs§
- Configures the behavior of consumer fetching and streaming
- Builder for
ConsumerConfig
. - Builder for
ConsumerConfigExt
. - An interface for consuming events from a particular partition
- Record that can be used by Consumer which needs access to metadata
- The request payload when using a Consumer SmartModule.
Enums§
- Strategy used to select which partitions and from which topics should be streamed by the
MultiplePartitionConsumer
- Indicates the type of SmartModule as well as any special data required
Traits§
- Extension of
Stream
trait with offset management capabilities.