如何配置Debezium Oracle连接器同步Oracle表列注释元数据至Kafka

要让Debezium Oracle连接器同步表和列的COMMENT注释元数据到Kafka，需要配置以下连接器属性：

• include.schema.changes=true：开启数据库模式变更（含注释元数据）的同步，会将元数据写入指定的schema历史主题，同时CDC事件的schema部分也会包含这些元数据。
• schema.history.internal.kafka.topic=your-schema-history-topic：指定存储模式历史的Kafka主题，必须配置该属性才能启用schema变更捕获功能。
• database.comment.handler=io.debezium.connector.oracle.handler.OracleCommentHandler：指定Oracle专用的注释处理器，负责解析表和列的COMMENT内容并将其加入元数据。
• include.comments=true：显式开启表与列注释信息的捕获，确保注释被包含到生成的schema及CDC事件元数据中。

补充说明 #

配置完成后，表的COMMENT会出现在CDC事件的schema字段对应的表定义里，列的COMMENT则会在对应字段的定义中以comment属性存在，你定义的JSON格式注释内容会被完整保留。另外需要注意，Debezium Oracle连接器版本需至少为1.9及以上，该版本才引入了注释处理器功能。

内容的提问来源于stack exchange，提问作者DataDoer