[GitHub] [kafka] mjsax commented on a change in pull request #11368: KAFKA-13261: Add support for custom partitioners in foreign key joins

mjsax commented on a change in pull request #11368: URL: https://github.com/apache/kafka/pull/11368#discussion_r729526952 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/TableJoined.java ## @@ -0,0 +1,119 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] mjsax commented on a change in pull request #11368: KAFKA-13261: Add support for custom partitioners in foreign key joins

mjsax commented on a change in pull request #11368: URL: https://github.com/apache/kafka/pull/11368#discussion_r729526952 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/TableJoined.java ## @@ -0,0 +1,119 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] mjsax commented on a change in pull request #11368: KAFKA-13261: Add support for custom partitioners in foreign key joins

mjsax commented on a change in pull request #11368: URL: https://github.com/apache/kafka/pull/11368#discussion_r740505996 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java ## @@ -2117,12 +2118,37 @@ * @param the key type of

[GitHub] [kafka] mjsax commented on a change in pull request #11368: KAFKA-13261: Add support for custom partitioners in foreign key joins

mjsax commented on a change in pull request #11368: URL: https://github.com/apache/kafka/pull/11368#discussion_r729526952 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/TableJoined.java ## @@ -0,0 +1,119 @@ +/* + * Licensed to the Apache Software