1

我有两个主题-plansupplier

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。我怎样才能做到这一点?

4

0 回答 0