通往卡夫卡的甲骨文金门答案

【问题标题】：Oracle Golden Gate to Kafka通往卡夫卡的甲骨文金门
【发布时间】：2020-07-21 18:02:26
【问题描述】：

我们正在通过 Oracle Golden Gate 将 Oracle 表复制到 Kafka 主题。我们看到在 UPDATE 操作中某些列被设置为 null 或者 Payload 中缺少某些列。

例如-

 {
>     "table":"QASOURCE.TCUSTORD",
>     "op_type":"U",
>     "op_ts":"2015-11-05 18:45:39.000000",
>     "current_ts":"2016-10-05T10:15:51.310002",
>     "pos":"00000000000000004300",
>     "before":{
>         "CUST_CODE":"BILL",
>         "ORDER_DATE":"1995-12-31:15:00:00",
>         "PRODUCT_CODE":"CAR",
>         "ORDER_ID":765,
>         "PRODUCT_PRICE":15000.00,
>         "PRODUCT_AMOUNT":3,
>         "TRANSACTION_ID":100
>     },
>     "after":{
>         "CUST_CODE":"BILL",
>         "ORDER_DATE":"1995-12-31:15:00:00",
>         "PRODUCT_CODE":"CAR",
>         "ORDER_ID":765,
>         "PRODUCT_PRICE":14000.00
>     } }

在上面的示例中，缺少交易 ID。这是否意味着缺失的列被设置为空。

是否可以在有效载荷中包含所有列而不考虑修改。

【问题讨论】：

标签： apache-kafka oracle-golden-gate

【解决方案1】：

要包含所有列，需要在参数文件中将提取配置为 'UPDATERECORDFORMAT FULL' ，以便跟踪文件包含所有更新的列。你可以检查一下。

参考https://docs.oracle.com/en/middleware/goldengate/core/19.1/reference/updaterecordformat.html#GUID-9E3E2D2B-2578-4549-8A81-9F0EFBD7DD82

【讨论】：