Thanks for the KIP Ivan! I think it's a good feature to give advanced users more control, and allow them to build more efficient application.
Not sure if I like the proposed named though (the good old "naming things" discussion :)) Did you consider alternatives? What about - markAsPartitioned() - markAsKeyed() - skipRepartition() Not sure if there are other idea on a good name? -Matthias On 6/24/21 7:45 AM, Ivan Ponomarev wrote: > Hello, > > I'd like to start a discussion for KIP-759: > https://cwiki.apache.org/confluence/display/KAFKA/KIP-759%3A+Unneeded+repartition+canceling > > > This is an offshoot of the discussion of KIP-655 for a `distinct` > operator, which turned out to be a separate proposal. > > The proposal is quite trivial, however, we still might consider > alternatives (see 'Possible Alternatives' section). > > Regards, > > Ivan