功能介绍

推送流程

数据订阅功能将云数据库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
  }
  ]
}

消息内容配置：