GithubStar/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-10-28 19:19:22 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #868 from wzl12356/master

Browse Source 
kafka: update WFKafkaClient
This commit is contained in:
xiehan
2022-04-22 18:25:43 +08:00
committed by GitHub
parent fbc1e124c9 7fee1b92e3
commit f6a21c9287
2 changed files with 242 additions and 433 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/client/WFKafkaClient.cc
+239 -428
View File
File diff suppressed because it is too large Load Diff
src/client/WFKafkaClient.h
+3 -5
View File
@@ -127,8 +127,6 @@ private:
class WFKafkaClient
{
public:
WFKafkaClient();
// example: kafka://10.160.23.23:9000
// example: kafka://kafka.sogou
// example: kafka.sogou:9090
@@ -137,7 +135,7 @@ public:
int init(const std::string& broker_url, const std::string& group);
void deinit();
int deinit();
// example: topic=xxx&topic=yyy&api=fetch
// example: api=commit
@@ -147,14 +145,14 @@ public:
WFKafkaTask *create_kafka_task(int retry_max, kafka_callback_t cb);
void set_config(protocol::KafkaConfig conf);
public:
/* If you don't leavegroup manually, rebalance would be triggered */
WFKafkaTask *create_leavegroup_task(int retry_max,
kafka_callback_t callback);
public:
virtual ~WFKafkaClient();
protocol::KafkaMetaList *get_meta_list();
protocol::KafkaBrokerList *get_broker_list();