OGG BD (v12.3.2.1.1) を試して、Oracle DB (11.2.0.4) からのすべての変更を Kafka トピックに伝達します。
基本的なセットアップがすべて機能し、監視しているスキーマ/テーブルへの INSERT と DELETE がキャプチャされ、構成されたトピック (テーブルごとに 1 つのトピック) に Kafka メッセージが生成されます。これまでのところ、すべてが期待どおりです。
ただし、データベースに対する UPDATE 操作は機能しません。エラーは発生しませんが、トピックに対応するメッセージが表示されません。UPDATE が実際に証跡ファイルに伝播されることを logdump ユーティリティで確認しましたが、kafkahandler はそれを検出しません。
何が間違っているのでしょうか？構成は以下のとおりです
OGG PRM ファイル
SETENV (TZ = "UTC")
REPLICAT kafkajsn
TARGETDB LIBFILE libggjava.so SET property=dirprm/kafkajsn.props
REPORTCOUNT EVERY 1 MINUTES, RATE
REPERROR DEFAULT DISCARD
APPLYNOOPUPDATES
ALLOWNOOPUPDATES
GETTRUNCATES
GETUPDATEBEFORES
DDL INCLUDE MAPPED
GROUPTRANSOPS 100
-- all tables have an 'ID' column
MAP *.*, TARGET *.*, KEYCOLS(ID);
Kafkahandler パラメータ ファイル
gg.handlerlist = kafkahandler
gg.handler.kafkahandler.type=kafka
gg.handler.kafkahandler.KafkaProducerConfigFile=kafka_producer.properties
gg.handler.kafkahandler.topicMappingTemplate=${schemaName}_${tableName}
gg.handler.kafkahandler.keyMappingTemplate=${primaryKeys}
gg.handler.kafkahandler.SchemaTopicName=SCHEMA_CHANGES
gg.handler.kafkahandler.mode=op
gg.handler.kafkahandler.format=json_row
gg.handler.kafkahandler.format.includePrimaryKeys=true
gg.classpath=dirprm/:/etc/kafka/conf:/usr/hdp/current/kafka-broker/libs/*
javawriter.bootoptions=-Xmx1g -Xms1g -Djava.class.path=ggjava/ggjava.jar
REPLICAT の証跡ファイルのログダンプ (これは UPDATE ... SET コメント = 'foo122' WHERE id=... でした)
2019/05/04 21:10:02.000.601 GGSUnifiedUpdate Len 30 RBA 64926561
Name: ORDER (TDR Index: 19)
After Image: Partition 12 G s
0c00 0000 0400 0800 0000 0400 666f 6f31 0400 0a00 | ............foo1....
0000 0600 666f 6f31 3232 | ....foo122
Before Image Len 16 (x00000010)
BeforeColumnLen 12 (x0000000c)
Column 4 (x0004), Len 8 (x0008)
After Image Len 14 (x0000000e)
Column 4 (x0004), Len 10 (x000a)
編集：エラーメッセージ
エラーメッセージが表示されなかったと言ったのは間違っていました。表示されませんでした。破棄ファイル (.dsc) で取得します
Operation failed at seqno 45 rba 108411
Discarding record on action DISCARD on error 0
Problem replicating ORDER to ORDER
Mapping problem with unified update record (target format)...
*
TRANSACTION_COMMENT = folkjhlkjhlkjhkljl jk lj5345u
000000: 66 6f 6c 6b 6a 68 6c 6b 6a 68 6c 6b 6a 68 6b 6c |folkjhlkjhlkjhkl|
000010: 6a 6c 20 6a 6b 20 6c 6a 35 33 34 35 75 |jl jk lj5345u |
TRANSACTION_COMMENT = folkjhlkjhlkjhkljl jk ljjhlkjhlkh5345u
000000: 66 6f 6c 6b 6a 68 6c 6b 6a 68 6c 6b 6a 68 6b 6c |folkjhlkjhlkjhkl|
000010: 6a 6c 20 6a 6b 20 6c 6a 6a 68 6c 6b 6a 68 6c 6b |jl jk ljjhlkjhlk|
000020: 68 35 33 34 35 75 |h5345u |