Source-agnostic distributed change data capture system