ruanhang1993 commented on code in PR #3758:
URL: https://github.com/apache/flink-cdc/pull/3758#discussion_r1891536970
##########
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java:
##########
@@ -272,4 +272,13 @@ public class MySqlDataSourceOptions {
+ "The difference between
scan.newly-added-table.enabled and scan.binlog.newly-added-table.enabled
options is: \n"
+ "scan.newly-added-table.enabled: do
re-snapshot & binlog-reading for newly added table when restored; \n"
+ "scan.binlog.newly-added-table.enabled:
only do binlog-reading for newly added table during binlog reading phase.");
+
+ @Experimental
+ public static final ConfigOption<String> METADATA_LIST =
+ ConfigOptions.key("metadata.list")
+ .stringType()
+ .noDefaultValue()
+ .withDescription(
+ "List of readable metadata from SourceRecord to be
passed to downstream, split by `,`. "
+ + "Refer to MySqlReadableMetadata,
available readable metadata are: table_name,database_name,op_ts,row_kind.");
Review Comment:
There is only one metadata `op_ts` for mysql pipeline connector. We cannot
use it to generate the description.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
