[KAFKA-7071] specify number of partitions when using repartition logic

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Duplicate
• Component/s: streams
• Assignee: Boyang Chen
• Reporter: Boyang Chen
• Created: 18/Jun/18 17:32
• Updated: 18/Jun/18 20:52
• Resolved: 18/Jun/18 20:52

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