我有两个主题-plan和supplier
plantopic 有一个基于两列planCode+的复合键 (avro) memberAge。
suppliertopic 以 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。我怎样才能做到这一点?