一对多在Kafka中使用KTable的外部联接

Question

我有一个联系人发布到主题＃1，其中的键为contact.id。此外，还会将一个子表发布到主题＃2，其中键为subtable.id。现在，我需要做一个连接，如

select * from contact c outer join subtable st on c.id = st.id; 

表之间有1..n的关系。如何在此处执行带/不带lambda的聚合。

Answer 1

Kafka Streams API不支持1：n KTable-KTable尚未加入（版本号为1.0或更早版本）。

支持的唯一非主键连接是KStream-GlobalKTable连接。在这篇博客中找到

更多细节加入：https://www.confluent.io/blog/crossing-streams-joins-apache-kafka/

此外，还有1一个JIRA：N联接：https://issues.apache.org/jira/browse/KAFKA-3705