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)