[
https://issues.apache.org/jira/browse/KAFKA-2694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14975146#comment-14975146
]
ASF GitHub Bot commented on KAFKA-2694:
---------------------------------------
GitHub user ymatsuda opened a pull request:
https://github.com/apache/kafka/pull/365
KAFKA-2694: Task Id
@guozhangwang
* A task id is now a class, ```TaskId```, that has a task group id and a
partition id fields.
* ```TopologyBuilder``` assigns a task group id to a topic group. Related
methods are changed accordingly.
* A state store uses the partition id part of the task id as the change log
partition id.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ymatsuda/kafka task_id
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/365.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #365
----
commit 31375d79ad666c6a38a7566e729a9062c9a97563
Author: Yasuhiro Matsuda <[email protected]>
Date: 2015-10-26T21:08:56Z
TaskId class
----
> Make a task id be a composite id of a task group id and a partition id
> ----------------------------------------------------------------------
>
> Key: KAFKA-2694
> URL: https://issues.apache.org/jira/browse/KAFKA-2694
> Project: Kafka
> Issue Type: Sub-task
> Components: kafka streams
> Reporter: Yasuhiro Matsuda
> Fix For: 0.9.0.0
>
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
