X-Git-Url: https://git.verplant.org/?a=blobdiff_plain;f=src%2Fwrite_kafka.c;h=b6e89618ec9ddbf51738556171ace8b278944130;hb=881d288ab29676f19afd886730ab550c7d15c8fc;hp=c5c7e3df9b3bac47b78b3fd216b13655b308b2c1;hpb=585e552936cc92e437ce1f58695a6d1b3caf785e;p=collectd.git

diff --git a/src/write_kafka.c b/src/write_kafka.c
index c5c7e3df..b6e89618 100644
--- a/src/write_kafka.c
+++ b/src/write_kafka.c
@@ -111,6 +111,8 @@ static int kafka_handle(struct kafka_topic_context *ctx) /* {{{ */
         }
 
     	rd_kafka_conf_destroy(ctx->kafka_conf);
+    	ctx->kafka_conf = NULL;
+
     	INFO ("write_kafka plugin: created KAFKA handle : %s", rd_kafka_name(ctx->kafka));
 
 #ifdef HAVE_LIBRDKAFKA_LOGGER
@@ -132,6 +134,8 @@ static int kafka_handle(struct kafka_topic_context *ctx) /* {{{ */
 	}
 
     	rd_kafka_topic_conf_destroy(ctx->conf);
+	ctx->conf = NULL;
+
     	INFO ("write_kafka plugin: handle created for topic : %s", rd_kafka_topic_name(ctx->topic));
     }