From cab742790af18001785d11c1223011bc665c50a2 Mon Sep 17 00:00:00 2001 From: takaomag Date: Sun, 30 Oct 2016 04:47:57 +0000 Subject: [PATCH] Add rd_kafka_poll() at exit --- ngx_http_kafka_module.c | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/ngx_http_kafka_module.c b/ngx_http_kafka_module.c index 5f606cc..2ee4993 100644 --- a/ngx_http_kafka_module.c +++ b/ngx_http_kafka_module.c @@ -382,6 +382,12 @@ void ngx_http_kafka_exit_worker(ngx_cycle_t *cycle) main_conf = ngx_http_cycle_get_module_main_conf(cycle, ngx_http_kafka_module); + rd_kafka_poll(main_conf->rk, 0); + + while (rd_kafka_outq_len(main_conf->rk) > 0) { + rd_kafka_poll(main_conf->rk, 100); + } + // TODO: rd_kafka_topic_destroy(each loc conf rkt ); rd_kafka_destroy(main_conf->rk); }