Thank you. And thanks for the JIRA link. On Wed, Feb 8, 2017 at 12:22 AM, Matthias J. Sax <matth...@confluent.io> 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 weeks), that explains this, too. > > See https://issues.apache.org/jira/browse/KAFKA-3561 > > > -Matthias > > On 2/7/17 7:06 PM, Dmitry Minkovsky wrote: > > 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 required on join operations > occurring > > after > > > an operation that changes the key, i.e, selectKey, map(..), > > flatMap(..). > > > > Given that this is undocumented, can this functionality be relied on? It > is > > pretty nice when you don't care what the repartition topic is called. > > > >
