upsert kafka sink why not send all data that contain update_before,delete

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

upsert kafka sink why not send all data that contain update_before,delete

Jocean shi
Hi
      I have a question, upsert kafka sink why not send all data that
contain update_before,delete. if send all data, the source dot't need
add state to recover data,
and the state may be very lage.

Best
ocean.shi