gbase数据、南大通用产品文档：GBase8a配置onfig_kafka_[queueName]properties

进入同步工具conf 配置文件目录：
cd /opt/RTSyncInstall_8.6.13.1_build1/RTSync/conf
注意：
config_kafka_[queueName].properties 文件名中的queueName 必须与
config_task.xml 文件中的致。
1、需要将conf 目录下的
config_kafka_8tto8tMQ.properties 修改为
config_kafka_orato8aMQ.properties 文件，修改语句如下：
#mv config_kafka_orato8aMQ.properties
config_kafka_orato8aMQ.properties
2、
编辑config_kafka_orato8aMQ.properties 文件，
修改配kafka 相关连接参

GBase RTSync 同步工具手册
- 14 -
南大通用数据技术股份有限公司
数
#vim config_kafka_orato8aMQ.properties
只要修改以下几个参数红色字体参数：
1、topic.name 为Kafka 使用的topic 的名称，这个可以随意命名
topic.name= testtp
2、topic.enable.auto.create 为是否自动创建topic 的开关，
值为true
topic.enable.auto.create=true
3、topic.replication.num 为topic 的复制数量，
取值范围为大于0 且小
于节点数量
topic.replication.num=1
4、bootstrap.servers 为每台Kafka 节点的IP 和端口号；
bootstrap.servers=172.16.3.19:9092,172.16.3.119:9092
5、zookeeper.connect 为每台Zookeeper 节点的IP 和端口号；
zookeeper.connect=172.16.3.19:2181,172.16.3.119:2181
6、group.id 为Kafka 的消费者的唯一组id；
group.id=test
以下为测试环境config_kafka_orato8aMQ.properties 文件参数配置：

GBase RTSync 同步工具手册
南大通用数据技术股份有限公司
- 15 -
topic.name=testtp
#is auto create topic name,default false
topic.enable.auto.create=true
#topic backup number, >0,<=brokers num
topic.replication.num=1
#producer conf
bootstrap.servers=172.16.3.19:9092,172.16.3.119:9092
#wait count to commit
kafka.batch.commit.count=1000
#wait time to commit
kafka.batch.commit.time=300
#kafka resend times
kafka.resend.max.retries=3
#kafka send result has confirm (send successed or send failed)
kafka.send.issuccess=true
#client send max data size. default:brokers message.max.bytes
send.data.max.size=104857600
#kafka
acknowledgement mechanism :0,1,all
kafka.acks=all
#kafka.producer.paramers=request.timeout.ms=60000;max.request.size=1
05857600;acks=1;compression.type=gzip
kafka.producer.paramers=request.timeout.ms=30000;metadata.fetch.time
out.ms=60000;linger.ms=1
#consumer conf
zookeeper.connect=172.16.3.19:2181,172.16.3.119:2181
group.id=test
auto.commit.interval.ms=5000
auto.commit.offset.enable=false
zookeeper.sync.time.ms=3000
zookeeper.session.timeout.ms=6000
#message max size for consumer ,suggest :fetch.message.max.bytes =
send.data.max.size=1000000
fetch.message.max.bytes=104857600
kafka.consumer.paramers=

GBase RTSync 同步工具手册
- 16 -
南大通用数据技术股份有限公司

ifx_lo_col_info() 函数设置 LO-specification 结构的字段为指定的数据库列的列级别
存储特征。
语法
mint ifx_lo_col_info(column_name, LO_spec)
char *column_name;
ifx_lo_create_spec_t *LO_spec;
column_name
指向包含您想要使用其列级别存储特征的数据库列的名称的缓冲区的指针。
LO_spec
指向在其中存储 column_name 的列级别存储特征的 LO-specification
结构的指 针。

用法
ifx_lo_col_info() 函数将 LO_spec 指向的 LO-specification 结构的
指端设置为 column_name 数据库列的存储特征。如果此指定了的列没有为其定
义的列级别存储特征，则数据库服务器使用继承的存储特征。

column_name 缓冲区必须以下列格式指定列名称：
database@server_name:table.column

如果该列在符合 ANSI 的数据库中，则您还可包括 owner_name，如下：
database@server_name:owner.table.column

重要： 在您调用 ifx_lo_col_info() 之前，您必须调用 ifx_lo_def_create_spec() 函数。


返回代码
0
函数成功。
<0
函数不成功，且返回值指示失败的原因。

GBase 8s ESQL/C 编程指南
南大通用数据技术股份有限公司
- 773 -

若要使用对象资源管理器，必须先将其连接到服务器上。可以通过已注册服务器连接，也
可以直接点击“连接到对象资源管理器”，打开“连接到服务器”窗口，直接输入服务器名称、
数据库、实例名、字符集编码、登录名和密码以及SSL 设置进行连接。

GBase 8s 企业管理器用户手册
南大通用数据技术股份有限公司

11

图：连接到服务器
用户可以随时断开对象资源管理器与服务器的连接。在对象资源管理器中，右击服务器，
然后单击“断开连接”，或者在菜单的“文件”中选择“断开与对象资源管理器的连接”选项。