[ https://issues.apache.org/jira/browse/SAMZA-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Daniel Nishimura updated SAMZA-2022: ------------------------------------ Description: SystemConsumers multiplexes the register with offset calls to each SystemConsumer. The basic logic that is needed in register() is {code:java} if there is a startpoint for the SSP and the SystemConsumer implements StartpointVisitor call SystemConsumer#visit(SSP, Startpoint) else call SystemConsumer#register(SSP, checkpointOffset:String){code} Part of this is to also investigate how startpoints affects the MessageChooser logic. > Startpoints - SystemConsumers (not to be confused with SystemConsumer) > modifications including integration with MessageChooser. > ------------------------------------------------------------------------------------------------------------------------------- > > Key: SAMZA-2022 > URL: https://issues.apache.org/jira/browse/SAMZA-2022 > Project: Samza > Issue Type: Bug > Affects Versions: 1.1 > Reporter: Daniel Nishimura > Assignee: Daniel Nishimura > Priority: Major > > SystemConsumers multiplexes the register with offset calls to each > SystemConsumer. The basic logic that is needed in register() is > {code:java} > if there is a startpoint for the SSP and the SystemConsumer implements > StartpointVisitor > call SystemConsumer#visit(SSP, Startpoint) > else > call SystemConsumer#register(SSP, checkpointOffset:String){code} > Part of this is to also investigate how startpoints affects the > MessageChooser logic. -- This message was sent by Atlassian JIRA (v7.6.3#76005)