Hello,

I'm looking into side input patterns especially slowly updating global
window side inputs -
https://beam.apache.org/documentation/patterns/side-inputs/

It'd be useful if we need to enrich eg) order records with customer
details where customer details would be taken as a side input.

Let's say we have two Kafka topics, one for client records and the other
for order records. For the enrichment to work properly, consumption of
order records should wait until all customer records are read.

Can you please inform me if it is achievable?

Cheers,
Jaehyeon

Reply via email to