flink sql cdc支持额外字段问题

[casel.chen]

flink sql 
cdc写入kafka，期望kafka消息带上数据库database，表table，变更时间和变更标记+I/-U/+U/-D这几个特殊字段，目前来看是做不到的，对吗？