zheguang opened a new pull request, #22221: URL: https://github.com/apache/kafka/pull/22221
This patch implements KIP-759: Unneeded repartition cancelling. The "unneeded" part is entirely by the user's own judgement :) A stream with key-changing operation can be marked as partitioned as intended to avoid repartition inserted to its topology. The main use case is for aggregation by a "composite key" -- a stream partitioned by key A can readily aggregate by composite key (A, B) without repartition. The reason being given two records, if their (A, B) are equal, then their A is equal. Test: - `markAsPartitioned` is no-op when no key changing - `markAsPartitioned` should not repartition in resulting topology - IQ should work when query for the original key intended by `markAsPartitioned` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
