Skip to content

AcceptsLatestSeenOffsetHandler

AcceptsLatestSeenOffsetHandler is a utility that can setLatestSeenOffsetOnSources on SparkDataStreams with support for AcceptsLatestSeenOffset.

setLatestSeenOffsetOnSources

setLatestSeenOffsetOnSources(
  offsets: Option[OffsetSeq],
  sources: Seq[SparkDataStream]): Unit

setLatestSeenOffsetOnSources...FIXME


setLatestSeenOffsetOnSources is used when: