推送流程

數據訂閱功能將云數據庫HBase增強版（云原生多模數據庫Lindorm）表格的增量數據消息主動推送至下游Kafka，推送流程如下。

功能特點

實時數據訂閱功能的信息投遞方式有以下特點：

• 支持主鍵級別保序，對于同一個主鍵的更新操作，會按照其更新的順序存儲和消費。

• 支持數據處理語義為至少一次（At-least-once）語義，即同一條數據可能因為內部重試而被重復消費。如果您需要設置為精確一次（Exactly Once）語義，請提交工單聯系我們。

消息格式

LindormStreams消息支持獲取更新后整行的數據以及更新前的值，詳細消息內容：

{
  "op" : <opType>             // 操作類型，可選Put、DeleteFamily
  "table" : <tableName>       // 表名
  "ts" : <defaultVersion>     // 默認版本，列數據中如果沒有ts值時取該值作為版本
  "keyOnly":<keyOnly>         // 是否只包含主鍵數據
  "data" : [
    {
      "type" : <type>          // 列數據類型
      "name" : <name>          // 列名
      "ts" : <version>         // 數據版本，如果沒有該值，取默認版本（ts）的值作為版本
      "value" : <value>        // 值，如果沒有該值，則表中值為null
  },
  {
      "type" : <type>          // 列數據類型
      "name" : <name>          // 列名
      "ts" : <version>         // 數據版本，如果沒有該值，取默認版本（ts）的值作為版本
      "value" : <value>        // 值，如果沒有該值，則表中值為null
  }
  ]
}

消息內容配置：