Jakob Homan created SAMZA-89:
--------------------------------
Summary: 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
Fix For: 0.7.0
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.1#6144)
