[ https://issues.apache.org/jira/browse/KAFKA-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15174546#comment-15174546 ]
ASF GitHub Bot commented on KAFKA-3311: --------------------------------------- GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/990 KAFKA-3311: Prepare internal source topics before calling partition grouper You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K3311 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/990.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 #990 ---- commit b4c45b3d43cb0bdeb144e60c42b3e2d88afbe4f9 Author: Guozhang Wang <wangg...@gmail.com> Date: 2016-03-01T22:39:01Z KAFKA-3311 v1 ---- > Move co-partition checking to PartitionAssignor and auto-create internal > topics > ------------------------------------------------------------------------------- > > Key: KAFKA-3311 > URL: https://issues.apache.org/jira/browse/KAFKA-3311 > Project: Kafka > Issue Type: Sub-task > Reporter: Guozhang Wang > Assignee: Guozhang Wang > > Right now the internal topics management (i.e. re-partition topics for now) > is buggy such that it was not auto-created by the assignor. We need to fix > this by: > 1) moving co-paritition info into the assignor. > 2) let assignor create the internal topics with the right number of > partitions as: if co-partitioned, equal to the other partitions; otherwise if > there are other source topics in the sub-topology, equal to the maximum of > other partitions; otherwise equal to the number of tasks writing to this > topic. -- This message was sent by Atlassian JIRA (v6.3.4#6332)