gbase数据、南大通用产品文档：GBase8a_gbase_kafka_producter_queue_buffering_max_messages

默认值10000000
取值范围[1,10000000]
集群数据导出到kafka 新增对应kafka 集群的配置参数，
该参数为一批中最多的消

GBase 8a MPP Cluster 产品手册
6 附录
文档版本953（2022-04-10）
南大通用数据技术股份有限公司
1606
息数，对应kafka 配置中的queue.buffering.max.messages。

函数说明
CURRENT_DATE 和CURRENT_DATE()等价于CURDATE()。
示例
示例1：使用CURRENT_DATE()函数返回日期。
gbase> SELECT CURRENT_DATE() FROM dual;
+----------------+
| CURRENT_DATE() |
+----------------+
| 2020-04-01
|
+----------------+
1 row in set
示例2：使用CURRENT_DATE 变量返回日期。
gbase> SELECT CURRENT_DATE FROM dual;
+---------------+
| CURRENT_DATE
|
+---------------+
| 2020-04-01
|
+---------------+
1 row in set
示例3：使用CURDATE()函数返回日期。

GBase 8a MPP Cluster 产品手册
5 数据库管理指南
文档版本953（2022-09-15）
南大通用数据技术股份有限公司
783
gbase> SELECT CURDATE() FROM dual;
+------------+
| CURDATE()
|
+------------+
| 2020-04-01 |
+------------+
1 row in set

产品架构
同步工具总体采用分布式组件架构模式，
将整个系统分为多个分布式组件，
每个组件根据所处的部署位置，提供不同的服务，通过组件的交互实现完整的
数据同步功能。
GBase RTSync 实时同步系统由四个子系统组件组成，分别是数据捕获组
件、
消息队列组件、
数据投递组件和管理组件，
每个组建可以分开部署也可以
部署在一起：

数据捕获组件，从数据源获取并解析增量数据逻辑日志，按照特定的协议
标准封装后发送给消息队列；

消息队列组件，传输和缓冲数据捕获组件发送的数据。目前支持Kafka 以
及Rabbit MQ，两者均可保证高可用；

数据投递组件，从消息队列组件中获取协议数据，并根据目标库的类型，
组织和优化数据，将数据写入目标数据库；

管理组件，启、停和监控数据捕获、投递组件，校验源和目标端数据同步
相关配置信息。
同步工具产品架构图如下：

GBase RTSync 同步工具手册
- 6 -
南大通用数据技术股份有限公司
图2- 2GBase RTSync 系统架构图