mirror of
https://github.com/sogou/workflow.git
synced 2026-02-08 01:33:17 +08:00
update docs
This commit is contained in:
@@ -99,7 +99,7 @@ compress_type | int | NoCompress | produce消息的压缩类型
|
||||
client_id | char * | NULL | 表示client的id
|
||||
check_crcs | bool | false | fetch任务中是否校验消息的crc32
|
||||
offset_store | int | 0 | 加入消费者组时,是否使用上次提交offset,1表示使用指定的offset,0表示优先使用上次提交
|
||||
sasl_mechanisms | char * | NULL | sasl认证类型,目前只支持plain,持续开发中
|
||||
sasl_mechanisms | char * | NULL | sasl认证类型,目前支持plain和scram
|
||||
sasl_username | char * | NULL | sasl认证所需的username
|
||||
sasl_password | char * | NULL | sasl认证所需的password
|
||||
|
||||
@@ -304,3 +304,24 @@ void kafka_callback(WFKafkaTask *task)
|
||||
...
|
||||
}
|
||||
~~~
|
||||
|
||||
# 认证
|
||||
认证信息需要在配置中设置,以sasl为例:
|
||||
~~~cpp
|
||||
int main(int argc, char *argv[])
|
||||
{
|
||||
...
|
||||
client = new WFKafkaClient();
|
||||
client->init(url);
|
||||
|
||||
task = client->create_kafka_task("api=fetch&topic=xxx&topic=yyy", 3, kafka_callback);
|
||||
config.set_sasl_username("fetch");
|
||||
config.set_sasl_password("fetch-secret");
|
||||
config.set_sasl_mech("SCRAM-SHA-256");
|
||||
task->set_config(std::move(config));
|
||||
|
||||
...
|
||||
task->start();
|
||||
...
|
||||
}
|
||||
~~~
|
||||
Reference in New Issue
Block a user