Re: Kafka Streams: Is automatic repartitioning before joins public/stable API?

2017-02-08 Thread Dmitry Minkovsky
Thank you. And thanks for the JIRA link. On Wed, Feb 8, 2017 at 12:22 AM, Matthias J. Sax wrote: > Yes, you can rely on this. > > The feature was introduced in Kafka 0.10.1 and will stay like this. We > already updated the JavaDocs (for upcoming 0.10.2, that is going to be > released the next we

Re: Kafka Streams: Is automatic repartitioning before joins public/stable API?

2017-02-07 Thread Matthias J. Sax
Yes, you can rely on this. The feature was introduced in Kafka 0.10.1 and will stay like this. We already updated the JavaDocs (for upcoming 0.10.2, that is going to be released the next weeks), that explains this, too. See https://issues.apache.org/jira/browse/KAFKA-3561 -Matthias On 2/7/17 7

Kafka Streams: Is automatic repartitioning before joins public/stable API?

2017-02-07 Thread Dmitry Minkovsky
I accidentally stumbled upon `repartitionRequired` and `repartitionForJoin` in `KStreamImpl`, which are examined/called before KStream join operations to determine whether a repartition is needed. The javadoc to `repartitionForJoin` explains the functionality: > Repartition a stream. This is