一對多在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