gbase数据、南大通用产品文档：GBase8aa 与kafka 集群的安全认证

8a 支持kafka 集群加密的两种方式：

kerberos 认证
详细操作可参考4.9.12.4 GBase 8a 与kafka 数据源的Kerberos 认证章节。

简单密码认证
Kafka0.10 版本后引入了简单用户名/密码
（SASL/PLAIN）
认证机制，
8a 支持kafka
的简单用户名/密码认证机制，在8a 集群与broker 之间认证。8a 新增配置参数
gbase_kafka_username 和
gbase_kafka_password ，使用时需要在gnode 和
gcluster 配置文件中配置这两个参数，指定kafka 认证使用的用户名和密码，8a
将使用配置的用户名/密码在与kafka 连接时做认证。
示例1：
配置参数gbase_kafka_username 和gbase_kafka_password，执行加载
set global gbase_kafka_username='gbase';
set global gbase_kafka_password='gbase';
LOAD
DATA
INFILE
'kafka://192.168.6.95:9092/yuehaoyu?duration=0'
INTO
TABLE test.t1 fields TERMINATED BY '|' DATA_FORMAT 3;
加载执行成功
如不配置参数，则报错：
ERROR 1733 (HY000): (GBA-01EX-700) GBase general error: Task 594750 failed,
Failed to acquire metadata: Local: Timed out
示例2：
loader consumer 进行加载
配置gbase_kafka_username 和gbase_kafka_password
create kafka consumer kafka_load_test1 loader topic yuehaoyu brokers
'192.168.6.95:9092' duration 3000 into table test.t1 fields TERMINATED BY
'|' DATA_FORMAT 3 null_value '\N';
start kafka consumer kafka_load_test1;
加载成功

GBase 8a MPP Cluster 产品手册
4 管理员指南
文档版本953（2022-04-10）
南大通用数据技术股份有限公司
471
如不配置参数，则报错：
ERROR 1707 (HY000): gcluster command error: can not connect to kafka with
the brokers and topic you specified

GBase 8a MPP Cluster 产品手册
4 管理员指南
文档版本953（2022-04-10）
南大通用数据技术股份有限公司
472

 摘要：
返回上一个gbase_fetch_field()所使用的字段光标的定义。该值可用作
gbase_field_seek()的参量。
 语法：
GBASE_FIELD_OFFSET gbase_field_tell(GBASE_RES *res);
 参数：
 返回值：
字段光标的当前偏移量。

GBase 8a 程序员手册C API 篇


- 18 -

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

PG_STAT_XACT_USER_FUNCTIONS 视图包含每个函数的执行的统计信息。
名称
类型
描述
funcid
oid
函数标识。
schemaname
name
模式的名称。
funcname
name
函数名称。
calls
bigint
函数被调用的次数。
total_time
double precision
函数的总执行时长。
self_time
double precision
当前线程调用函数的总的时长。