Logical

+-----+---------------+------------------------+------------------+---------+----------+----------+----------+------------+------------+-------------+
|pid  |client_addr    |usename                 |application_name  |state    |write_lsn |flush_lsn |replay_lsn|write_lag_ms|flush_lag_ms|replay_lag_ms|
+-----+---------------+------------------------+------------------+---------+----------+----------+----------+------------+------------+-------------+
|17856|192.168.126.141|replication_user        |walreceiver       |streaming|0/13D6A2A8|0/13D6A2A8|0/13D6A2A8|null        |null        |null         |
|19699|192.168.126.1  |logical_replication_user|Debezium Streaming|streaming|0/13D6A2A8|null      |null      |null        |null        |null         |
+-----+---------------+------------------------+------------------+---------+----------+----------+----------+------------+------------+-------------+

After

+-----+---------------+------------------------+------------------+---------+----------+----------+----------+------------+------------+-------------+
|pid  |client_addr    |usename                 |application_name  |state    |write_lsn |flush_lsn |replay_lsn|write_lag_ms|flush_lag_ms|replay_lag_ms|
+-----+---------------+------------------------+------------------+---------+----------+----------+----------+------------+------------+-------------+
|17856|192.168.126.141|replication_user        |walreceiver       |streaming|0/1B0A9690|0/1B0A9690|0/1B0A9690|null        |null        |null         |
|19699|192.168.126.1  |logical_replication_user|Debezium Streaming|streaming|0/1B0A9690|0/1B09B460|0/1B09B460|4906.965    |114990.367  |114990.367   |
+-----+---------------+------------------------+------------------+---------+----------+----------+----------+------------+------------+-------------+

GET http://localhost:8083/connectors/<name>/status

-- Create parent table with partitioning
CREATE TABLE sales2 (
    id bigint NOT NULL,
    sale_date DATE NOT NULL,
    amount NUMERIC(10, 2) NOT NULL,
    customer TEXT NOT NULL,
    PRIMARY KEY (id, sale_date)
) PARTITION BY RANGE (sale_date);

-- Create default partition
Create table sales2_default partition of sales default;

-- January 2025 partition
create table sales2_2025_01 partition of sales for values from ('2025-01-01') to ('2025-02-01');
create table sales2_2025_02 partition of sales for values from ('2025-02-01') to ('2025-03-01');
create table sales2_2025_03 partition of sales for values from ('2025-03-01') to ('2025-04-01');
create table sales2_2025_04 partition of sales for values from ('2025-04-01') to ('2025-05-01');
create table sales2_2025_05 partition of sales for values from ('2025-05-01') to ('2025-06-01');
create table sales2_2025_06 partition of sales for values from ('2025-06-01') to ('2025-07-01');
create table sales2_2025_07 partition of sales for values from ('2025-07-01') to ('2025-08-01');
create table sales2_2025_08 partition of sales for values from ('2025-08-01') to ('2025-09-01');
create table sales2_2025_09 partition of sales for values from ('2025-09-01') to ('2025-10-01');
create table sales2_2025_10 partition of sales for values from ('2025-10-01') to ('2025-11-01');
create table sales2_2025_11 partition of sales for values from ('2025-11-01') to ('2025-12-01');
create table sales2_2025_12 partition of sales for values from ('2025-12-01') to ('2026-01-01');