Re: How to reprocess certain events in Flink?

2019-12-17 Thread Pooja Agrawal
ording the transaction_id(s) which are > already processed. And then 2) would not be a problem with the unique > transaction_id assumption. > > Thanks, > Zhu Zhu > > Pooja Agrawal 于2019年12月17日周二 下午9:17写道: > >> >> Hi, >> >> I have a use cas

Fwd: How to reprocess certain events in Flink?

2019-12-17 Thread Pooja Agrawal
t and we may want to reprocess those events with new value. Since this is just a value change, the transaction_id will be same. The idempotency logic will not allow to reprocess the events. What are the ways to handle such scenarios in flink? Thanks Pooja -- Warm Regards, Pooja Agrawal