[
https://issues.apache.org/jira/browse/SAMZA-89?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Riccomini updated SAMZA-89:
---------------------------------
Fix Version/s: (was: 0.7.0)
> Provide topics task is responsible for in InitableTask
> ------------------------------------------------------
>
> Key: SAMZA-89
> URL: https://issues.apache.org/jira/browse/SAMZA-89
> Project: Samza
> Issue Type: Improvement
> Components: container
> Affects Versions: 0.6.0
> Reporter: Jakob Homan
> Priority: Minor
>
> Right now tasks can determine what partition they're handling via the
> TaskContext.getPartition method and, with some work, what topics the entire
> job is responsible via the config that's passed into InitableTask as well.
> But there's no easy way to figure out what topics a specific task is
> responsible for, particularly when dealing with a heterogeneous number of
> partitions per topic. We should have a method on TaskContext that returns a
> set of the topics this task instance will be receiving messages for.
> Arguably, this method (and the accompanying getPartition) should be included
> in TaskCoordinator so that tasks don't have to implement InitableTask just to
> get this info (and in the event that in the future we have dynamic
> topics/partitions per task).
--
This message was sent by Atlassian JIRA
(v6.2#6252)
