Hi, you can manually create a topic with the number of partitions you want to have and use this topic via through()
KStream input = ...
input.map().through("manually-created-topic").join(...)
However, both KStream and KTable need to have the same number of
partitions for perform the join. Thus, you might need to create a topic
(with the same number of partitions) for the table, too.
See
http://docs.confluent.io/3.0.0/streams/developer-guide.html#joining-streams
-Matthias
On 07/13/2016 11:59 PM, Poul Costinsky wrote:
> Hi! I am prototyping some code using Kafka Streams, and have a question. I
> need to map a stream into another (with different partition key) and join it
> with a table. How do I control number of partitions of the mapped stream?
>
> Thanks!
>
> Poul Costinsky
> Chief Architect
>
> <http://www.adbrain.com/>
> (360) 207-1753 <tel:%28360%29%20207-1753>
>
>
>
>
>
signature.asc
Description: OpenPGP digital signature
