Skip to content

Conversation

qingfei1994
Copy link

This closes https://issues.apache.org/jira/browse/FLINK-38110
When there's column name in Chinese in PG tables, Postgresql connector with pgoutput plugin will decode them as garbled characters, especially during incremental capure.

The reason is when handling column names and table names,

io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder

doesn't convert the String to utf8 charset,
This pr copied PgOutputMessageDecoder from debezium and add a new method readUTF8String(ByteBufer bytebuffer)
and use the method when decoding column names.

Unit test is supplemented for this case.

jennychen and others added 14 commits September 2, 2025 22:49
[FLINK-38110] fix PostgreSQL connector reads Chinese columns with garble charactor
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant