消費Hologres Binlog需要注意如下事項：

• 僅Hologres V0.9及以上版本支持消費Hologres Binlog；僅Hologres V1.3.21及以上版本支持配置引擎白名單，HologresV1.3.21以下版本當前暫不支持配置引擎白名單，開啟白名單后，會造成Binlog消費失敗。如果您的實例版本低于所要求實例版本，請您加入Hologres釘釘群進行反饋，詳情可參見在線支持。

• Hologres支持單表級別的Binlog功能，支持行存表和列存表，以及從Hologres V1.1版本開始支持行列共存表。開啟Binlog后，理論上列存表的開銷要大于行存表的開銷。因此對于數(shù)據(jù)更新頻繁的場景，建議為使用行存存儲格式的表開啟Binlog。

• Hologres Binlog的支持情況以及開啟、配置Hologres Binlog，請參見訂閱Hologres Binlog。

• 僅阿里云Flink支持消費Hologres Binlog。Holohub模式下Flink消費Hologres Binlog只支持簡單數(shù)據(jù)類型，從Flink 6.0.3版本開始，支持通過JDBC模式消費Hologres Binlog，相比Holohub，JDBC支持更多的數(shù)據(jù)類型，詳情請參見Blink/Flink與Hologres的數(shù)據(jù)類型映射。同時增加了部分權(quán)限限制，詳情請參見權(quán)限說明。

• 目前不支持消費分區(qū)父表的Binlog。

• Hologres V2.0版本起有限支持Holohub模式；V2.1版本起下線Holohub模式，全面轉(zhuǎn)為JDBC模式。在您升級Hologres版本前，請參考Holohub模式切換到JDBC模式，查看您當前正在使用Holohub模式的Flink任務(wù)，并按步驟升級Flink VVR作業(yè)版本，然后升級Hologres實例。

該模式下Source消費的Binlog數(shù)據(jù)是作為普通的Flink數(shù)據(jù)傳遞給下游節(jié)點的，即所有數(shù)據(jù)都是作為Insert類型的數(shù)據(jù)，可以根據(jù)業(yè)務(wù)情況選擇如何處理特定hg_binlog_event_type類型的數(shù)據(jù)。Hologres表開啟Binlog后，在Flink中源表（非CDC模式）使用如下DDL可以實時消費Binlog。

create table test_message_src_binlog_table(
  hg_binlog_lsn BIGINT,
  hg_binlog_event_type BIGINT,
  hg_binlog_timestamp_us BIGINT,
  id INTEGER,
  title VARCHAR,
  body VARCHAR
) with (
  'connector'='hologres',
  'dbname'='<yourDbname>',
  'tablename'='<yourTablename>',
  'username'='<yourAccessID>',
  'password'='<yourAccessSecret>',
  'endpoint'='<yourEndpoint>',
  'binlog' = 'true',
  'binlogMaxRetryTimes' = '10',
  'binlogRetryIntervalMs' = '500',
  'binlogBatchReadSize' = '100'
);

• 三個binlogxxx 參數(shù)表示Binlog系統(tǒng)字段，命名和類型是固定的不能修改。

• 其他字段是跟用戶字段一一對應(yīng)，必須是全小寫。

該模式下Source消費的Binlog數(shù)據(jù)，將根據(jù)hg_binlog_event_type自動為每行數(shù)據(jù)設(shè)置準確的Flink RowKind類型（INSERT、DELETE、UPDATE_BEFORE、UPDATE_AFTER），這樣就能完成表的數(shù)據(jù)的鏡像同步，類似MySQL和Postgres的CDC功能。

Hologres表開啟Binlog后，在Flink中源表（CDC模式）使用如下DDL可以實時消費Binlog。

create table test_message_src_binlog_table(
  id INTEGER,
  title VARCHAR,
  body VARCHAR
) with (
  'connector'='hologres',
  'dbname'='<yourDbname>',//Hologres的DB名
  'tablename'='<yourTablename>',//Hologres的表名
  'username'='<yourAccessID>',//當前賬號的access id
  'password'='<yourAccessSecret>',//當前賬號的access key
  'endpoint'='<yourEndpoint>',//Hologres的vpc網(wǎng)絡(luò)地址
  'binlog' = 'true',
  'cdcMode' = 'true',
  'binlogMaxRetryTimes' = '10',
  'binlogRetryIntervalMs' = '500',
  'binlogBatchReadSize' = '100'
);