delete before insert with sql_raw

[artemklevtsov]

Hi,

I tried to process messages from the kafka and produce output to postgres.

How can I delete from the database before process main payload?

Now redpanda procude batch and DELETE FROM called for the whole batch.

I tried split processor for the input without success.

Conditional output query with when selects only one query.

Actual (also see database log below):

delete id 0
delete id 1
delete id 2
insert id 0
insert id 0
insert id 1
insert id 1
insert id 2
insert id 2

Expected

delete id 0
insert id 0
insert id 0
delete id 1
insert id 1
insert id 1
delete id 2
insert id 2
insert id 2

To reproduce:

docker compose up -d
redpanda-connect run gen.yaml
redpanda-connect run process.yaml
docker compose logs postgres &> pg.log

docker-compose.yaml:

services:
  redpanda:
    image: redpandadata/redpanda:latest
    command:
      - redpanda start
      - --smp 1
      - --overprovisioned
      - --kafka-addr PLAINTEXT://0.0.0.0:29092,OUTSIDE://0.0.0.0:9092
      - --advertise-kafka-addr PLAINTEXT://redpanda:29092,OUTSIDE://localhost:9092
    ports:
      - 9092:9092
      - 8081:8081
      - 8082:8082
      - 9644:9644
  console:
    image: redpandadata/console:latest
    entrypoint: /bin/sh
    environment:
      CONFIG_FILEPATH: /tmp/config.yml
      CONSOLE_CONFIG_FILE: |
        kafka:
          brokers: ["redpanda:29092"]
    ports:
      - 8080:8080
    depends_on:
      - redpanda
    command: -c "echo \"$$CONSOLE_CONFIG_FILE\" > /tmp/config.yml; /app/console"
  postgres:
    image: postgres:17-alpine
    environment:
      POSTGRES_PASSWORD: pass
    ports:
      - 5432:5432
    volumes:
      - ./pg.conf:/etc/postgresql/postgresql.conf
    command: postgres -c config_file=/etc/postgresql/postgresql.conf

pg,conf:

listen_addresses = '*'
log_statement = 'all'

gen.yaml:

logger:
  level: debug

input:
  generate:
    count: 9
    interval: 0.1s
    mapping: |
      #!blobl
      root.id = counter(min: 0) % 3
      root.items = [{"id": 1, "value": "test"}, {"id": 2, "value": "test"}]

output:
  redpanda:
    seed_brokers:
      - localhost:9092
    topic: test

process.yaml:

logger:
  level: debug

input:
  redpanda:
    seed_brokers:
      - localhost:9092
    topics:
      - test:0
  processors:
    - split:
        size: 1
    - log:
        message: receive record
        fields_mapping: |
          #!blobl
          root.offset = @kafka_offset
          root.partition = @kafka_partition
          root.index = batch_index()

pipeline:
  threads: 1
  processors:
    - sql_raw:
        driver: postgres
        dsn: postgresql://postgres:pass@localhost:5432/postgres?search_path=public
        exec_only: true
        query: DELETE FROM test WHERE id = $1;
        args_mapping: |
          #!blobl
          root = [ this.id ]
    - mapping: |
        #!blobl
        root = this.explode("items")
    - unarchive:
        format: json_array
    - mapping: |
        #!blobl
        root.id = this.id
        root.item_id = this.items.id
        root.item_value = this.items.value

output:
  # stdout: {}
  sql_raw:
    driver: postgres
    dsn: postgresql://postgres:pass@localhost:5432/postgres?search_path=public
    query: |
      INSERT INTO test (id, item_id, item_value)
      VALUES ($1, $2, $3);
    args_mapping: |
      #!blobl
      root = [this.id, this.item_id, this.item_value]
    init_statement: |
      CREATE TABLE IF NOT EXISTS test (id int8, item_id int8, item_value text, PRIMARY KEY (id, item_id));
      TRUNCATE test;

pg.log:

Details

postgres-1  | The files belonging to this database system will be owned by user "postgres".
postgres-1  | This user must also own the server process.
postgres-1  | 
postgres-1  | The database cluster will be initialized with locale "en_US.utf8".
postgres-1  | The default database encoding has accordingly been set to "UTF8".
postgres-1  | The default text search configuration will be set to "english".
postgres-1  | 
postgres-1  | Data page checksums are disabled.
postgres-1  | 
postgres-1  | fixing permissions on existing directory /var/lib/postgresql/data ... ok
postgres-1  | creating subdirectories ... ok
postgres-1  | selecting dynamic shared memory implementation ... posix
postgres-1  | selecting default "max_connections" ... 100
postgres-1  | selecting default "shared_buffers" ... 128MB
postgres-1  | selecting default time zone ... UTC
postgres-1  | creating configuration files ... ok
postgres-1  | running bootstrap script ... ok
postgres-1  | sh: locale: not found
postgres-1  | 2026-04-16 14:42:41.876 UTC [35] WARNING:  no usable system locales were found
postgres-1  | performing post-bootstrap initialization ... ok
postgres-1  | initdb: warning: enabling "trust" authentication for local connections
postgres-1  | syncing data to disk ... ok
postgres-1  | 
postgres-1  | 
postgres-1  | Success. You can now start the database server using:
postgres-1  | 
postgres-1  |     pg_ctl -D /var/lib/postgresql/data -l logfile start
postgres-1  | 
postgres-1  | initdb: hint: You can change this by editing pg_hba.conf or using the option -A, or --auth-local and --auth-host, the next time you run initdb.
postgres-1  | waiting for server to start....2026-04-16 14:42:42.948 GMT [41] LOG:  starting PostgreSQL 17.9 on x86_64-pc-linux-musl, compiled by gcc (Alpine 15.2.0) 15.2.0, 64-bit
postgres-1  | 2026-04-16 14:42:42.949 GMT [41] LOG:  listening on Unix socket "/var/run/postgresql/.s.PGSQL.5432"
postgres-1  | 2026-04-16 14:42:42.952 GMT [44] LOG:  database system was shut down at 2026-04-16 14:42:42 GMT
postgres-1  | 2026-04-16 14:42:42.956 GMT [41] LOG:  database system is ready to accept connections
postgres-1  |  done
postgres-1  | server started
postgres-1  | 2026-04-16 14:42:43.048 GMT [50] LOG:  statement: SELECT 1 FROM pg_database WHERE datname = 'postgres' ;
postgres-1  | 
postgres-1  | /usr/local/bin/docker-entrypoint.sh: ignoring /docker-entrypoint-initdb.d/*
postgres-1  | 
postgres-1  | waiting for server to shut down....2026-04-16 14:42:43.050 GMT [41] LOG:  received fast shutdown request
postgres-1  | 2026-04-16 14:42:43.051 GMT [41] LOG:  aborting any active transactions
postgres-1  | 2026-04-16 14:42:43.053 GMT [41] LOG:  background worker "logical replication launcher" (PID 47) exited with exit code 1
postgres-1  | 2026-04-16 14:42:43.053 GMT [42] LOG:  shutting down
postgres-1  | 2026-04-16 14:42:43.054 GMT [42] LOG:  checkpoint starting: shutdown immediate
postgres-1  | 2026-04-16 14:42:43.061 GMT [42] LOG:  checkpoint complete: wrote 3 buffers (0.0%); 0 WAL file(s) added, 0 removed, 0 recycled; write=0.001 s, sync=0.002 s, total=0.009 s; sync files=2, longest=0.001 s, average=0.001 s; distance=0 kB, estimate=0 kB; lsn=0/14ED290, redo lsn=0/14ED290
postgres-1  | 2026-04-16 14:42:43.063 GMT [41] LOG:  database system is shut down
postgres-1  |  done
postgres-1  | server stopped
postgres-1  | 
postgres-1  | PostgreSQL init process complete; ready for start up.
postgres-1  | 
postgres-1  | 2026-04-16 14:42:43.160 GMT [1] LOG:  starting PostgreSQL 17.9 on x86_64-pc-linux-musl, compiled by gcc (Alpine 15.2.0) 15.2.0, 64-bit
postgres-1  | 2026-04-16 14:42:43.160 GMT [1] LOG:  listening on IPv4 address "0.0.0.0", port 5432
postgres-1  | 2026-04-16 14:42:43.160 GMT [1] LOG:  listening on IPv6 address "::", port 5432
postgres-1  | 2026-04-16 14:42:43.162 GMT [1] LOG:  listening on Unix socket "/var/run/postgresql/.s.PGSQL.5432"
postgres-1  | 2026-04-16 14:42:43.165 GMT [55] LOG:  database system was shut down at 2026-04-16 14:42:43 GMT
postgres-1  | 2026-04-16 14:42:43.168 GMT [1] LOG:  database system is ready to accept connections
postgres-1  | 2026-04-16 14:43:08.905 GMT [60] LOG:  statement: CREATE TABLE IF NOT EXISTS test (id int8, item_id int8, item_value text, PRIMARY KEY (id, item_id));
postgres-1  | 	TRUNCATE test;
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.646 GMT [62] LOG:  execute <unnamed>: DELETE FROM test WHERE id = $1;
postgres-1  | 2026-04-16 14:43:09.646 GMT [62] DETAIL:  Parameters: $1 = '0'
postgres-1  | 2026-04-16 14:43:09.646 GMT [62] LOG:  execute <unnamed>: DELETE FROM test WHERE id = $1;
postgres-1  | 2026-04-16 14:43:09.646 GMT [62] DETAIL:  Parameters: $1 = '1'
postgres-1  | 2026-04-16 14:43:09.646 GMT [60] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.646 GMT [60] DETAIL:  Parameters: $1 = '0', $2 = '1', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.646 GMT [62] LOG:  execute <unnamed>: DELETE FROM test WHERE id = $1;
postgres-1  | 2026-04-16 14:43:09.646 GMT [62] DETAIL:  Parameters: $1 = '2'
postgres-1  | 2026-04-16 14:43:09.646 GMT [62] LOG:  execute <unnamed>: DELETE FROM test WHERE id = $1;
postgres-1  | 2026-04-16 14:43:09.646 GMT [62] DETAIL:  Parameters: $1 = '0'
postgres-1  | 2026-04-16 14:43:09.647 GMT [62] LOG:  execute <unnamed>: DELETE FROM test WHERE id = $1;
postgres-1  | 2026-04-16 14:43:09.647 GMT [62] DETAIL:  Parameters: $1 = '1'
postgres-1  | 2026-04-16 14:43:09.647 GMT [62] LOG:  execute <unnamed>: DELETE FROM test WHERE id = $1;
postgres-1  | 2026-04-16 14:43:09.647 GMT [62] DETAIL:  Parameters: $1 = '2'
postgres-1  | 2026-04-16 14:43:09.647 GMT [62] LOG:  execute <unnamed>: DELETE FROM test WHERE id = $1;
postgres-1  | 2026-04-16 14:43:09.647 GMT [62] DETAIL:  Parameters: $1 = '0'
postgres-1  | 2026-04-16 14:43:09.657 GMT [60] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.657 GMT [60] DETAIL:  Parameters: $1 = '0', $2 = '2', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.657 GMT [62] LOG:  execute <unnamed>: DELETE FROM test WHERE id = $1;
postgres-1  | 2026-04-16 14:43:09.657 GMT [62] DETAIL:  Parameters: $1 = '1'
postgres-1  | 2026-04-16 14:43:09.657 GMT [62] LOG:  execute <unnamed>: DELETE FROM test WHERE id = $1;
postgres-1  | 2026-04-16 14:43:09.657 GMT [62] DETAIL:  Parameters: $1 = '2'
postgres-1  | 2026-04-16 14:43:09.658 GMT [67] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.658 GMT [67] DETAIL:  Parameters: $1 = '1', $2 = '1', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.659 GMT [68] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.659 GMT [68] DETAIL:  Parameters: $1 = '2', $2 = '1', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.659 GMT [69] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.659 GMT [69] DETAIL:  Parameters: $1 = '0', $2 = '1', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.660 GMT [69] ERROR:  duplicate key value violates unique constraint "test_pkey"
postgres-1  | 2026-04-16 14:43:09.660 GMT [69] DETAIL:  Key (id, item_id)=(0, 1) already exists.
postgres-1  | 2026-04-16 14:43:09.660 GMT [69] STATEMENT:  INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.660 GMT [67] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.660 GMT [67] DETAIL:  Parameters: $1 = '1', $2 = '2', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.660 GMT [71] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.660 GMT [71] DETAIL:  Parameters: $1 = '1', $2 = '1', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.660 GMT [69] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.660 GMT [69] DETAIL:  Parameters: $1 = '0', $2 = '2', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.660 GMT [69] ERROR:  duplicate key value violates unique constraint "test_pkey"
postgres-1  | 2026-04-16 14:43:09.660 GMT [69] DETAIL:  Key (id, item_id)=(0, 2) already exists.
postgres-1  | 2026-04-16 14:43:09.660 GMT [69] STATEMENT:  INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.660 GMT [71] ERROR:  duplicate key value violates unique constraint "test_pkey"
postgres-1  | 2026-04-16 14:43:09.660 GMT [71] DETAIL:  Key (id, item_id)=(1, 1) already exists.
postgres-1  | 2026-04-16 14:43:09.660 GMT [71] STATEMENT:  INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.660 GMT [69] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.660 GMT [69] DETAIL:  Parameters: $1 = '1', $2 = '2', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.660 GMT [75] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.660 GMT [75] DETAIL:  Parameters: $1 = '2', $2 = '1', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.660 GMT [76] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.660 GMT [76] DETAIL:  Parameters: $1 = '0', $2 = '1', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.660 GMT [76] ERROR:  duplicate key value violates unique constraint "test_pkey"
postgres-1  | 2026-04-16 14:43:09.660 GMT [76] DETAIL:  Key (id, item_id)=(0, 1) already exists.
postgres-1  | 2026-04-16 14:43:09.660 GMT [76] STATEMENT:  INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.661 GMT [76] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.661 GMT [76] DETAIL:  Parameters: $1 = '0', $2 = '2', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.661 GMT [75] ERROR:  duplicate key value violates unique constraint "test_pkey"
postgres-1  | 2026-04-16 14:43:09.661 GMT [75] DETAIL:  Key (id, item_id)=(2, 1) already exists.
postgres-1  | 2026-04-16 14:43:09.661 GMT [75] STATEMENT:  INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.661 GMT [76] ERROR:  duplicate key value violates unique constraint "test_pkey"
postgres-1  | 2026-04-16 14:43:09.661 GMT [76] DETAIL:  Key (id, item_id)=(0, 2) already exists.
postgres-1  | 2026-04-16 14:43:09.661 GMT [76] STATEMENT:  INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.661 GMT [68] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.661 GMT [68] DETAIL:  Parameters: $1 = '2', $2 = '2', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.661 GMT [76] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.661 GMT [76] DETAIL:  Parameters: $1 = '2', $2 = '2', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.661 GMT [77] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.661 GMT [77] DETAIL:  Parameters: $1 = '1', $2 = '1', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.661 GMT [78] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.661 GMT [78] DETAIL:  Parameters: $1 = '2', $2 = '1', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.661 GMT [77] ERROR:  duplicate key value violates unique constraint "test_pkey"
postgres-1  | 2026-04-16 14:43:09.661 GMT [77] DETAIL:  Key (id, item_id)=(1, 1) already exists.
postgres-1  | 2026-04-16 14:43:09.661 GMT [77] STATEMENT:  INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.661 GMT [78] ERROR:  duplicate key value violates unique constraint "test_pkey"
postgres-1  | 2026-04-16 14:43:09.661 GMT [78] DETAIL:  Key (id, item_id)=(2, 1) already exists.
postgres-1  | 2026-04-16 14:43:09.661 GMT [78] STATEMENT:  INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.661 GMT [77] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.661 GMT [77] DETAIL:  Parameters: $1 = '1', $2 = '2', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.661 GMT [78] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.661 GMT [78] DETAIL:  Parameters: $1 = '2', $2 = '2', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.662 GMT [69] ERROR:  duplicate key value violates unique constraint "test_pkey"
postgres-1  | 2026-04-16 14:43:09.662 GMT [69] DETAIL:  Key (id, item_id)=(1, 2) already exists.
postgres-1  | 2026-04-16 14:43:09.662 GMT [69] STATEMENT:  INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.662 GMT [77] ERROR:  duplicate key value violates unique constraint "test_pkey"
postgres-1  | 2026-04-16 14:43:09.662 GMT [77] DETAIL:  Key (id, item_id)=(1, 2) already exists.
postgres-1  | 2026-04-16 14:43:09.662 GMT [77] STATEMENT:  INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.664 GMT [78] ERROR:  duplicate key value violates unique constraint "test_pkey"
postgres-1  | 2026-04-16 14:43:09.664 GMT [78] DETAIL:  Key (id, item_id)=(2, 2) already exists.
postgres-1  | 2026-04-16 14:43:09.664 GMT [78] STATEMENT:  INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.664 GMT [76] ERROR:  duplicate key value violates unique constraint "test_pkey"
postgres-1  | 2026-04-16 14:43:09.664 GMT [76] DETAIL:  Key (id, item_id)=(2, 2) already exists.
postgres-1  | 2026-04-16 14:43:09.664 GMT [76] STATEMENT:  INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.664 GMT [62] LOG:  execute <unnamed>: DELETE FROM test WHERE id = $1;
postgres-1  | 2026-04-16 14:43:09.664 GMT [62] DETAIL:  Parameters: $1 = '0'
postgres-1  | 2026-04-16 14:43:09.665 GMT [67] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.665 GMT [67] DETAIL:  Parameters: $1 = '0', $2 = '1', $3 = 'test'
postgres-1  | 2026-04-16 14:43:09.668 GMT [67] LOG:  execute <unnamed>: INSERT INTO test (id, item_id, item_value)
postgres-1  | 	VALUES ($1, $2, $3);
postgres-1  | 	
postgres-1  | 2026-04-16 14:43:09.668 GMT [67] DETAIL:  Parameters: $1 = '0', $2 = '2', $3 = 'test'

Regards