package stream
Type Members
-
case class
CheckpointMark(kafkaPartitionId: String, offset: Long) extends Product with Serializable
This class represents consumer offsets state attached to a consumed partition.
This class represents consumer offsets state attached to a consumed partition. It can be used to commit offsets back to kafka broker or Stream REST API
- case class StreamOutput(nodeBaseURL: String, subscriptionId: String) extends Product with Serializable