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. >
signature.asc
Description: OpenPGP digital signature
