Helper interface attached to an underlying system to fetch information about streams, partitions, offsets, etc.
SystemConsumer is the interface that must be implemented by any system that wishes to integrate with Samza.
SystemProducers are how Samza writes messages from
This class represents a message envelope that is received by a StreamTask for each message that is received from a partition of a specific input stream.
Streams in Samza consist of both the stream name and the system to which the stream belongs.
SystemAdmins use this class to return useful metadata about a stream's offset and partition information.
Provides offset information for a given SystemStreamPartition.
OffsetType is an enum used to define which offset should be used when reading from a SystemStreamPartition for the first time.