Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-2022

Startpoints - SystemConsumers (not to be confused with SystemConsumer) modifications including integration with MessageChooser.

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 1.1
    • 1.1
    • None
    • None

    Description

      SystemConsumers multiplexes the register with offset calls to each SystemConsumer. The basic logic that is needed in register() is

      if there is a startpoint for the SSP and the SystemConsumer implements StartpointVisitor
          call Startpoint#apply(SSP, StartpointVisitor)
      else
          call SystemConsumer#register(SSP, checkpointOffset:String)

      Part of this is to also investigate how startpoints affects the MessageChooser logic.

      Attachments

        Issue Links

          Activity

            People

              dnishimura Daniel Nishimura
              dnishimura Daniel Nishimura
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: