[ https://issues.apache.org/jira/browse/KAFKA-7071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Boyang Chen updated KAFKA-7071: ------------------------------- Description: Hey there, I was wondering whether it makes sense to specify number of partitions of the output topic from a repartition operation like groupBy, flatMap, etc. The current DSL doesn't support adding a customized repartition topic which has customized number of partitions. For example, I want to reduce the input topic from 8 partitions to 1, there is no easy solution but to create a new topic instead. cc [~guozhang] [~liquanpei] was:Hey there, I was wondering whether it makes sense to specify number of partitions of the output topic from a repartition operation like groupBy, flatMap, etc. The current DSL doesn't support adding a customized repartition topic which has customized number of partitions. For example, I want to reduce the input topic from 8 partitions to 1, there is no easy solution but to create a new topic instead. > specify number of partitions when using repartition logic > --------------------------------------------------------- > > Key: KAFKA-7071 > URL: https://issues.apache.org/jira/browse/KAFKA-7071 > Project: Kafka > Issue Type: Improvement > Components: streams > Reporter: Boyang Chen > Assignee: Boyang Chen > Priority: Major > > Hey there, I was wondering whether it makes sense to specify number of > partitions of the output topic from a repartition operation like groupBy, > flatMap, etc. The current DSL doesn't support adding a customized repartition > topic which has customized number of partitions. For example, I want to > reduce the input topic from 8 partitions to 1, there is no easy solution but > to create a new topic instead. > cc [~guozhang] [~liquanpei] -- This message was sent by Atlassian JIRA (v7.6.3#76005)