Module salesforce 

Stream-driven Salesforce CDC capture.

Functions

capture_stream

Captures a decoded CDC stream into the sync journal and checkpoints replay positions.

load_replay_id

Loads the stored replay cursor for a CDC stream.