CREATE SOURCE exposure_api_db WITH (
    connector = 'postgres-cdc',
    hostname='redacted',
    port=5432,
    username='redacted',
    password='redacted',
    database.name='postgres',
    schema.name='public',
    table.name='cdc_test',
    slot.name='risingwave_slot',
    publication.name='risingwave_publication',
    auto.schema.changes=true
);

CREATE TABLE cdc_table (
    category varchar,
    timestamp timestamptz,
    value numeric,
    PRIMARY KEY (category)
) WITH (
    snapshot='true'
)
FROM exposure_api_db TABLE 'public.cdc_test';

CREATE MATERIALIZED VIEW cdc_table_mv AS
WITH subscription AS CHANGELOG FROM cdc_table 
SELECT 
    category,
    timestamp, 
    value, 
    case 
        when changelog_op = 1 then 'create' 
        when changelog_op = 3 then 'update' 
        when changelog_op = 4 then 'delete' 
    end AS __op,
    _changelog_row_id::bigint AS __row_id
FROM subscription;

SELECT * FROM cdc_table_mv;

│ compute 2025-05-20T16:13:50.63862789Z ERROR risingwave_connector_node: engine#5541 terminated with error. message: Connector configuration is not valid. Error while validating connector config: FATAL: password authentication failed for user "quentin"  ││
│ thread="rw-dbz-engine-runner-5541" class="com.risingwave.connector.source.core.DbzCdcEngineRunner"                                                                                                                                                          ││
│ compute 2025-05-20T16:13:50.638703789Z  WARN actor{otel.name="Actor 29724" actor_id=29724 prev_epoch=8553917820764160 curr_epoch=8553917886300160}:executor{otel.name="Source 741C00002712"}: risingwave_stream::executor::source::reader_stream: build str ││
│ eam source reader error, retry in 1s error=Connector configuration is not valid. Error while validating connector config: FATAL: password authentication failed for user "quentin"                                                                          ││
│ compute                                                                                                                                                                                                                                                     ││
│ compute Backtrace:                                                                                                                                                                                                                                          ││
│ compute    0: anyhow::kind::Adhoc::new                                                                                                                                                                                                                      ││
│ compute              at ./root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/anyhow-1.0.86/src/backtrace.rs:27:14                                                                                                                                    ││
│ compute    1: risingwave_jni_core::Java_com_risingwave_java_binding_Binding_sendCdcSourceErrorToChannel::{{closure}}                                                                                                                                        ││
│ compute              at ./risingwave/src/jni_core/src/lib.rs:1049:58                                                                                                                                                                                        ││
│ compute    2: risingwave_jni_core::execute_and_catch::{{closure}}                                                                                                                                                                                           ││
│ compute              at ./risingwave/src/jni_core/src/lib.rs:222:59                                                                                                                                                                                         ││
│ compute    3: <core::panic::unwind_safe::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once                                                                                                                                                 ││
│ compute              at ./rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/core/src/panic/unwind_safe.rs:272:9                                                                                                                                        ││
│ compute    4: std::panicking::try::do_call                                                                                                                                                                                                                  ││
│ compute              at ./rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panicking.rs:587:40                                                                                                                                                ││
│ compute    5: std::panicking::try                                                                                                                                                                                                                           ││
│ compute              at ./rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panicking.rs:550:19                                                                                                                                                ││
│ compute    6: std::panic::catch_unwind                                                                                                                                                                                                                      ││
│ compute              at ./rustc/f9e0239a7bc813b4aceffc7f069f4797cde3175c/library/std/src/panic.rs:359:14                                                                                                                                                    ││
│ compute    7: risingwave_common::util::panic::rw_catch_unwind::{{closure}}                                                                                                                                                                                  ││
│ compute              at ./risingwave/src/common/src/util/panic.rs:44:9                                                                                                                                                                                      ││
│ compute    8: tokio::task::task_local::LocalKey<T>::scope_inner                                                                                                                                                                                             ││
│ compute              at ./root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.40.0/src/task/task_local.rs:217:19                                                                                                                              ││
│ compute    9: tokio::task::task_local::LocalKey<T>::sync_scope                                                                                                                                                                                              ││
│ compute              at ./root/.cargo/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.40.0/src/task/task_local.rs:173:15                                                                                                                              ││
│ compute   10: risingwave_common::util::panic::rw_catch_unwind                                                                                                                                                                                               ││
│ compute              at ./risingwave/src/common/src/util/panic.rs:42:5                                                                                                                                                                                      ││
│ compute   11: risingwave_jni_core::execute_and_catch                                                                                                                                                                                                        ││
│ compute              at ./risingwave/src/jni_core/src/lib.rs:222:11                                                                                                                                                                                         ││
│ compute   12: Java_com_risingwave_java_binding_Binding_sendCdcSourceErrorToChannel                                                                                                                                                                          ││
│ compute              at ./risingwave/src/jni_core/src/lib.rs:1044:5                                                                                                                                                                                         ││
│ compute   13: <unknown>                                                                                                                                                                                                                                     ││
│ compute                                                                                                                                                                                                                                                     ││
│ compute