Run Alternitive

[marckeelingiv]

Currently the only mthods to run are

engine.run()
Utils.run_engine_async(engine=engine, timeout_sec=0)

It would be great if we could wait for debezium to finish in the case of snapshot.mode = 'initial_only' and then end the run automatically.

[ismailsimsek]

Thar requires to implement a custom process that regularly reads the logs to detect a specific message indicating the snapshot is complete. When it finds this message, it should terminate the snapshot process.

its more suitable to add this feature to debezium, as one of the snapshot modes.