我有两个主题-plan
和supplier
plan
topic 有一个基于两列planCode
+的复合键 (avro) memberAge
。
supplier
topic 以 column 为键supplierId
,它包含 columnplanCode
但不包含memberAge
.
KStream<String, GenericRecord> supplier = builder.stream(supplier_topic);
KTable<GenericRecord, GenericRecord> planTable = builder.table(plan_topic);
SUPPLIER (KStream) : supplierId -> ...., planCode ,..
PLAN (KTable/ GlobalKTable) : {planCode, memberAge} -> value
我想做一个供应商的左连接计划plan_code
。我怎样才能做到这一点?