设置名称空间

类名

指定类名 com.datamirror.ts.target.publication.userexit.sample.kafka.KcopMultiRowAvroLiveAuditIntegrated。

将命令附加到属性文件

您的属性文件位于 CDC_kafka_installation_directory/conf/filename.properties中。

属性文件内容

[cdc@beauty1 conf]$ cat kcops_prop.properties
schema.registry.url=http://localhost:8081
audit.jcfs=ENTTYP,CCID,TIMSTAMP
MODIFY_SCHEMA_value.SOURCEDB.ORACLE.TAB3_SET_NAMESPACE=x.y.z

curl 命令

要检查模式，请使用以下 curl 命令:

[root@beauty1 bin]# curl -X GET -i -H "Content-Type: application/vnd.schemaregistry.v1+json"
http://localhost:8081/subjects/cdc_kafka_testing.kmralai.sourcedb.oracle.tab3-
value/versions/latest

输出：

{"type":"record","name":"TAB3","namespace":"x.y.z","fields":[{"name":"PCKOL","type":[{"type":"string","logicalType":"DECIMAL","dbColumnName":"PCKOL","precision":38,"scale":0},"null"],"doc":"","default":"0"},{"name":"PCKOLDATA","type":[{"type":"string","logicalType":"VARCHAR","dbColumnName":"PCKOLDATA","length":255},"null"],"doc":"","default":""},{"name":"A_ENTTYP","type":"string"},{"name":"A_CCID","type":"string"},{"name":"A_TIMSTAMP","type":"string"}]}