From 0cd1f786b7a80152f0d3ad282df7290d7a452fff Mon Sep 17 00:00:00 2001 From: Patrick Stephens Date: Sun, 19 Jul 2026 15:18:02 +0100 Subject: [PATCH 1/3] out_azure_blob: add null check for worker exit Signed-off-by: Patrick Stephens --- plugins/out_azure_blob/azure_blob.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/plugins/out_azure_blob/azure_blob.c b/plugins/out_azure_blob/azure_blob.c index 57ffd90ad43..69bcc0713f9 100644 --- a/plugins/out_azure_blob/azure_blob.c +++ b/plugins/out_azure_blob/azure_blob.c @@ -2430,6 +2430,10 @@ static int cb_worker_exit(void *data, struct flb_config *config) struct worker_info *info; struct flb_azure_blob *ctx = data; + if (!ctx) { + return 0; + } + flb_plg_info(ctx->ins, "initializing worker"); info = FLB_TLS_GET(worker_info); From e92e981dcb689f201f7a62c10c3e82697f45e38d Mon Sep 17 00:00:00 2001 From: Patrick Stephens Date: Sun, 19 Jul 2026 15:19:26 +0100 Subject: [PATCH 2/3] out_nats: add null check for exit Signed-off-by: Patrick Stephens --- plugins/out_nats/nats.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/plugins/out_nats/nats.c b/plugins/out_nats/nats.c index 589b57061a4..ef4b8ea8042 100644 --- a/plugins/out_nats/nats.c +++ b/plugins/out_nats/nats.c @@ -231,6 +231,10 @@ int cb_nats_exit(void *data, struct flb_config *config) (void) config; struct flb_out_nats_config *ctx = data; + if (!ctx) { + return 0; + } + flb_upstream_destroy(ctx->u); flb_free(ctx); From ab972aa7f54c0edb6112280a374522a564c3f478 Mon Sep 17 00:00:00 2001 From: Patrick Stephens Date: Sun, 19 Jul 2026 15:20:46 +0100 Subject: [PATCH 3/3] out_kafka_rest: add null check for exit Signed-off-by: Patrick Stephens --- plugins/out_kafka_rest/kafka.c | 4 ++++ plugins/out_kafka_rest/kafka_conf.c | 4 ++++ 2 files changed, 8 insertions(+) diff --git a/plugins/out_kafka_rest/kafka.c b/plugins/out_kafka_rest/kafka.c index f1e5efc2d19..272c63df092 100644 --- a/plugins/out_kafka_rest/kafka.c +++ b/plugins/out_kafka_rest/kafka.c @@ -338,6 +338,10 @@ static int cb_kafka_exit(void *data, struct flb_config *config) { struct flb_kafka_rest *ctx = data; + if (!ctx) { + return 0; + } + flb_kr_conf_destroy(ctx); return 0; } diff --git a/plugins/out_kafka_rest/kafka_conf.c b/plugins/out_kafka_rest/kafka_conf.c index eae5dc9da81..f428c8f3be1 100644 --- a/plugins/out_kafka_rest/kafka_conf.c +++ b/plugins/out_kafka_rest/kafka_conf.c @@ -197,6 +197,10 @@ struct flb_kafka_rest *flb_kr_conf_create(struct flb_output_instance *ins, int flb_kr_conf_destroy(struct flb_kafka_rest *ctx) { + if (!ctx) { + return 0; + } + flb_free(ctx->topic); flb_free(ctx->http_user); flb_free(ctx->http_passwd);