bbejeck opened a new pull request #10150: URL: https://github.com/apache/kafka/pull/10150
This PR implements adding read-only access to the key for `KStream.join` as described in [KIP-149](https://cwiki.apache.org/confluence/display/KAFKA/KIP-149%3A+Enabling+key+access+in+ValueTransformer%2C+ValueMapper%2C+and+ValueJoiner) This PR as it stands does not affect the Streams Scala API. Updating the Streams Scala API will be done in a follow-up PR. Additionally, the original KIP did not include the `KTable` API, but I don't see any reason why we wouldn't want the same functionality there as well, this will be done in an additional follow-up PR after updating the existing KIP. Tests added ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
