PipelineEndOfStream
data class PipelineEndOfStream<K : WithStream, T>(val stream: DestinationStream.Descriptor) : PipelineEvent<K, T>
Broadcast at end-of-stream to all partitions to signal that the stream has ended.
Broadcast at end-of-stream to all partitions to signal that the stream has ended.