From 2d76f1df35607fbc565d28c764819187cf889dcf Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E4=BB=81=E6=9D=B0?= Date: Thu, 1 Aug 2019 09:38:40 +0800 Subject: [PATCH] Update lirenjie_vxlan_sapp.c --- lirenjie_vxlan_sapp.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lirenjie_vxlan_sapp.c b/lirenjie_vxlan_sapp.c index 695bbc4..2c90941 100644 --- a/lirenjie_vxlan_sapp.c +++ b/lirenjie_vxlan_sapp.c @@ -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();