Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 7 additions & 0 deletions docs/content/connectors/mysql-cdc.md
Original file line number Diff line number Diff line change
Expand Up @@ -776,3 +776,10 @@ This is because the MySQL user account uses `sha256_password` authentication whi
ALTER USER 'username'@'localhost' IDENTIFIED WITH mysql_native_password BY 'password';
FLUSH PRIVILEGES;
```
#### Q5: How to config `tableList` option when build MySQL CDC source in DataStream API?

The `tableList` option requires table name with database name rather than table name in DataStream API. For MySQL CDC source, the `tableList` option value should like 'my_db.my_table'.

#### Q6: How to config MySQL server timezone in DataStream API?

The timezone of MySQL server influences the data value of TIMESTAMP column in its binlog file, thus we need to consider the MySQL server timezone when deal record that contains TIMESTAMP column. You can refer `com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema` as an example when you define your custom deserializer to deal binlog data correctly.
8 changes: 8 additions & 0 deletions docs/content/connectors/postgres-cdc.md
Original file line number Diff line number Diff line change
Expand Up @@ -368,3 +368,11 @@ Data Type Mapping
</tbody>
</table>
</div>


FAQ
--------

#### Q1: How to config `tableList` option when build Postgres CDC source in DataStream API?

The `tableList` option requires table name with schema name rather than table name in DataStream API. For Postgres CDC source, the `tableList` option value should like 'my_schema.my_table'.