Re: Re-partitioning topic with through (Kafka Streams)

2018-07-31 Thread Guozhang Wang
Hello Francesco, Streams auto-created repartition topics's num.partitions are determined by the num.tasks of the writing sub-topology, which is then determined by the source topic's num.partitions in turn. There are some proposals about extending this coupling but not yet implemented: https://cwik

Re-partitioning topic with through (Kafka Streams)

2018-07-31 Thread Francesco Frontera
Hi, I have a question about topic repartitioning in Kafka Streams using `through` function. I try to explain the context Briefly: I have single topic A with two partitions: A:1:9 A:0:0 I try to create a repartitioned topic using Kafka Streams API: builder.stream("A").map<>((key, val) => KeyV