[ https://issues.apache.org/jira/browse/KAFKA-9302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997432#comment-16997432 ]
John Roesler commented on KAFKA-9302: ------------------------------------- Thanks for the report, [~mjsax]. It also comes to mind that we neglected to allow customizing the internal store implementation (it's always rocksdb, and the cache is disabled). Maybe we can design a config object solution to all of this together. > Allow custom partitioning in foreign-key joins > ---------------------------------------------- > > Key: KAFKA-9302 > URL: https://issues.apache.org/jira/browse/KAFKA-9302 > Project: Kafka > Issue Type: Improvement > Components: streams > Reporter: Matthias J. Sax > Priority: Major > Labels: needs-kip > > In the 2.4 release, we introduces foreign-key joins via KIP-213 (KAFKA-3705). > However, the API does not allow to work with a custom partitioning strategy, > ie, it always assumes that the both input tables use the default partitioner. > We should allow to pass in a custom partitioner for each side that can be > used when writing in the repartitions topics. -- This message was sent by Atlassian Jira (v8.3.4#803005)