Oracle CDC

Install

cargo install faucet-cli --features source-oracle-cdc
faucet init --source oracle-cdc

# Cargo.toml — use it as a library
cargo add faucet-source-oracle-cdc

Starter config

source:
  type: oracle-cdc
  config:
    # connect_string: ""    # Easy Connect (`host:1521/FREEPDB1`), TNS alias, or connect descriptor.
    # host: ""    # Database host.
    # port: 0    # Listener port.
    # service_name: ""    # Service name (e.g.
    # sid: ""    # Legacy SID.
    # username: ""    # Database user.
    # password: ""    # Password for `username`.
    # external_auth: false    # Authenticate with external credentials (OS authentication or a wallet holding the credentials) instead of `username` / `…
    # tls: { ... }    # TCPS settings applied to a `host`-form connection.
    tables: []    # REQUIRED — Tables to capture as `OWNER.TABLE`, in data-dictionary case (usually upper case).
    # start_position: { type: current }    # one of: current, earliest
      # --- Alternative variants — replace the block above with one of these ---
      # type: earliest
    # poll_interval: 1    # Seconds to wait between polls that find nothing new.
    # idle_timeout: 30    # End the fetch cycle after this long without a captured change, counted only once mining has reached the current SCN.
    # max_scn_window: 500000    # Largest SCN range mined per LogMiner session.
    # max_staged_records: 1000000    # Abort when one in-flight transaction buffers more than this many changes (bounded memory).
    # max_staged_records_total: null    # Abort when all open transactions together buffer more than this many changes, counting LOB pieces and folded updates.
    # batch_size: 1000    # `0` aggregates committed transactions into pages of up to 100,000 records, emitted at least every `idle_timeout`, each with its bookmark; otherwise each committed transaction is its own page.
    # max_connections: 2    # Maximum pooled sessions.
    # statement_timeout_secs: 600    # Per-round-trip call timeout in seconds (`0` disables).
    # flush_table: "FAUCET_LOGMNR_FLUSH"    # Table the source commits to before each mining window, forcing the log writer to flush redo up to the window's end SCN.
    # on_unsupported: null    # What to do with a change LogMiner cannot render as SQL for a tracked table (`UNSUPPORTED` rows, or a *dictionary mismatc…
    # state_key: ""    # Explicit state-store key.

Capabilities

Config fields