0
contact.idとしてkeyを使用してトピック＃1にテーブル連絡先を公開しています。また、サブテーブルは、topicable＃idというキーを持つトピック＃2に公開されます。今、私はように参加する必要がありますKafkaでKTableを使用して1対多の外部結合
select * from contact c outer join subtable st on c.id = st.id;
テーブル間に1..nの関係があります。ここでラムダの有無にかかわらず集計を実行する方法。