Good morning @rgurskis , I would really appreciate if you could tell me how exactly capture the “org.postgresql.util.PSQLException: ERROR: invalid byte sequence for encoding “UTF8”: 0x00” message to filter on value that starts with specific text and contains non-printable characters.
It was something you talked anout at “JdbcSinkConnector - error on INSERT (invalid byte sequence) - #4 by rgurskis”
The sink connector si something like this:
Mi sink json is something like
““transforms”: “unwrap, filterStout”,
“transforms.unwrap.type”: “io.debezium.transforms.ExtractNewRecordState”,
“transforms.unwrap.drop.tombstones”: “false”,
“transforms.filterStout.type” : “io.confluent.connect.transforms.Filter$Value”,
“transforms.filterStout.filter.condition”: WHAT SHOULD BE THE CONDITION LIKE IN HERE TO CAPTURE “ERROR: invalid byte sequence for encoding “UTF8”: 0x00"”,
“transforms.filterStout.filter.type” : “exclude”,”
I am stuck with this and I would really appreciate your help.
Thanks a lot