samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Daniel Nishimura <dnishim...@gmail.com>
Subject [DISCUSS] SEP-18: Startpoints - Manipulating Starting Offsets for Input Streams
Date Tue, 11 Dec 2018 16:06:05 GMT
Hi all,

I am proposing SEP-18 which provides a more generic interface to rewind and
fast-forward input offsets. This will allow manipulating offsets not only
by specific offsets, but also by timestamp and other position types. Please
see the document linked below. The document is evolving as we explore the
feature through implementation, so please keep an eye out for changes.

https://cwiki.apache.org/confluence/display/SAMZA/SEP-18%3A+Startpoints+-+Manipulating+Starting+Offsets+for+Input+Streams

Thanks!
Dan Nishimura

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message