設定-エラー

クラス名

クラス名として com.datamirror.ts.target.publication.userexit.sample.kafka.KcopDefaultBehaviourIntegratedを指定します。

プロパティー・ファイルにコマンドを追加

プロパティー・ファイルは CDC_kafka_installation_directory/conf/filename.propertiesにあります。

プロパティー・ファイルの内容

schema.registry.url=http://localhost:8081
MODIFY_SCHEMA_value.SOURCEDB.ORACLE.TAB3_SET_IS-ERROR=true

curl コマンド

スキーマを確認するには、以下の curl コマンドを使用します。

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

出力:

{"type":"error","name":"TAB3","namespace":"value.SOURCEDB.ORACLE","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":""}]}