StreamSpec
SystemAdmin
SystemStream
- system:String- stream:String
OutgoingMessageEnvelope
- systemStream:SystemStream- keySerializerName:String- messageSerializerName:String- partitionKey:Object- key:Object- message:Object
SystemStreamMetadata
Partition
- partition: int
SystemConsumer
SystemProducer
SystemFactory
+ getProducer():SystemProcuder+ getConsumer():SystemConcumser+ getAdmin():SystemAdmin
SystemStreamPartition
- system : String- stream : String- partition : Partition
Startpoint
- creationTimestamp:long
