gfwleak/lirenjie-lrj-vxlan
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update lirenjie_vxlan_sapp.c

Browse Source
This commit is contained in:
李仁杰
2019-08-01 09:38:40 +08:00
parent c724263abe
commit 2d76f1df35
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
lirenjie_vxlan_sapp.c
View File

@@ -127,9 +127,9 @@ static int init_kafka(int partition_, char *brokers_, char *topic_)
/* Quick termination */
snprintf(tmp, sizeof(tmp), "%i", SIGIO);
rd_kafka_conf_set(conf, "internal.termination.signal", tmp, NULL, 0);
rd_kafka_conf_set(conf, "queue.buffering.max.messages", "1000000", kafka_errstr, sizeof(kafka_errstr));
rd_kafka_conf_set(conf, "topic.metadata.refresh.interval.ms", "600000",kafka_errstr, sizeof(kafka_errstr));
rd_kafka_conf_set(conf, "request.required.acks", "1", kafka_errstr, sizeof(kafka_errstr));
rd_kafka_conf_set(conf, "queue.buffering.max.messages", "1000000", errstr, sizeof(errstr));
rd_kafka_conf_set(conf, "topic.metadata.refresh.interval.ms", "600000",errstr, sizeof(errstr));
rd_kafka_conf_set(conf, "request.required.acks", "1", errstr, sizeof(errstr));
/*topic configuration*/
topic_conf = rd_kafka_topic_conf_new();