io.debezium.connector.postgresql.connection.PostgresReplicationConnection.startStreaming(Lsn, WalPositionLocator) uses config() method but that contains only JDBC configuration. It is necessary to store and use PostgreConnectorConfig to get retries and wait time parameters.