kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax" <matth...@confluent.io>
Subject Re: Kafka Streams question
Date Thu, 14 Jul 2016 08:08:52 GMT

you can manually create a topic with the number of partitions you want
to have and use this topic via through()

KStream input = ...


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.



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>

View raw message