CheckpointManager
constructor(catalog: DestinationCatalog, syncManager: SyncManager, outputConsumer: suspend (Reserved<CheckpointMessage>, Long, Long, Long) -> Unit, timeProvider: TimeProvider, socketMode: Boolean, namespaceMapper: NamespaceMapper)