返回首页

gbase数据、南大通用产品文档:GBase8a

更新日期:2024年09月11日

配置透明网关.......................................... 3



sword GCIThreadCreate (
void *hndl,
GCIError *err,
Void (*start)(void *),
void *arg,
GCIThreadId *tid,
GCIThreadHandle *tHnd

);

GBase 8s GCI 接口使用指南

南大通用数据技术股份有限公司 115

创建一个新的线程。
新线程首先执行对 start 指向的函数的调用,该函数由 arg 给出的参数启动。当该函数返
回时,新线程将终止。该函数不应返回值,而应接受一个参数,即 void。
当且仅当 tHnd 为非 NULL时,对 GCIThreadCreate() 的调用需与 GCIThreadClose() 的调
用匹配;如果 tHnd 为 NULL,则放置在 *tid 中的线程 ID 在调用线程中无效,因为生成
的线程终止的时间未知。
tid 参数应由 GCIThreadIdInit() 初始化,tHnd 应由 GCIThreadHndInit() 初始化。

参数
输入
/输出


hndl
输入/输出
GCI 环境或用户会话句柄
err
输入/输出
错误信息句柄,该接口调用失败时,错误信息会存在该句柄上
start
输入
新线程开始执行的函数
arg
输入
给出由 start 指向的函数的参数
tid
输入/输出
要创建的线程 id 指针
tHnd
输入/输出
要创建的线程句柄指针

如果执行成功,返回 GCI_SUCCESS,否则返回 GCI_ERROR。

默认值0
取值范围[0,1]
kafka 0.11 版本( 含) 以上支持EOS 特性,集群数据导出到kafka 也支持
EOS(exactly-once semantics 精确一次语义)配置,即不会重复生产和消费数据,包
含幂等性和事务性两种特性。开启事务性配置后,幂等性配置会连带置为开启。
参数gbase_kafka_producer_enable_idempotence 为幂等性开关,默认值为0,取值
范围0、1。
0 代表关闭幂等性,
1 代表开启幂等性。
开启幂等性功能,
可以保证导出的消息中
没有因为发送重试产生的重复消息(如果broker 端收到数据,
但是返回给发送端的
确认信息ACK 在网络中丢失会造成发送端再次发送重复消息)。