Guozhang Wang created KAFKA-3311:
------------------------------------
Summary: 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)
