Interface extends the more generic SystemAdmin interface TODO: Merge this interface method with SystemAdmin when we upgrade to JDK 1.8
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 entvelope that is received by a StreamTask for each message that is received from a partition of a specific input stream.
StreamSpec is a blueprint for creating, validating, or simply describing a stream in the runtime environment.
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.