2017-10-11 3 views
0

J'ai un contact de table publié au sujet # 1 avec clé comme contact.id. Une sous-table est également publiée sur le sujet n ° 2 avec la clé comme subtable.id. Maintenant, je dois faire une jointure commeun à plusieurs extérieur join En utilisant KTable dans Kafka

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

Il existe une relation 1..n entre les tables. Comment effectuer une agrégation avec/sans lambda ici. L'API Kafka Streams ne prend pas encore en charge les jointures KTable-KTable 1: n (version 1.0 ou antérieure)

Répondre