Chris Riccomini created SAMZA-603:
-------------------------------------
Summary: Expose more consumer controls to developers
Key: SAMZA-603
URL: https://issues.apache.org/jira/browse/SAMZA-603
Project: Samza
Issue Type: Bug
Components: container
Affects Versions: 0.9.0
Reporter: Chris Riccomini
Fix For: 0.10.0
Several overlapping feature requests have emerged. People want the ability to
programmatically:
# Add new input streams after a job has started.
# Pause consuming a stream for a period of time.
# Stop consuming a stream.
# Override offsets at both job start time, and after a job has been running for
a while (rewind/fast forward).
We don't really expose any of these controls to the StreamTask or
JobCoordinator in a pluggable way. This is an umbrella ticket to track this
work.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
