Re: [DISCUSS] KIP-221: Enhance KStream with Connecting Topic Creation and Repartition Hint

2019-06-11 Thread Matthias J. Sax
Boyang, Thanks for pushing this KIP. Re-reading it, it only allows to specify number of partitions for internally created repartition topics. I still believe, that using `through()` in it's current form might be too clumsy for some cases, because (talking to users) it's a regular use-case to repa

[DISCUSS] KIP-221: Enhance KStream with Connecting Topic Creation and Repartition Hint

2019-01-20 Thread Boyang Chen
Hey all, I would like to start a new discussion thread for refined KIP-221: https://cwiki.apache.org/confluence/display/KAFKA/KIP-221%3A+Enhance+KStream+with+Connecting+Topic+Creation+and+Repartition+Hint The major goal for this KIP is simplified to empower KStream #to and #groupBy APIs ability