* 优化 cdc SQLSinkBuilder KafkaSinkBuilder, filter to process * change "_" to "." * change "db" to config.getSchemaFieldName() * change "tableMap key" to table.getSchemaTableName()