diff --git a/plugins/filter_rewrite_tag/rewrite_tag.c b/plugins/filter_rewrite_tag/rewrite_tag.c index 0e3c22902da..8d961bbd4be 100644 --- a/plugins/filter_rewrite_tag/rewrite_tag.c +++ b/plugins/filter_rewrite_tag/rewrite_tag.c @@ -35,7 +35,6 @@ static int emitter_create(struct flb_rewrite_tag *ctx) { int ret; - int coll_fd; struct flb_input_instance *ins; ret = flb_input_name_exists(ctx->emitter_name, ctx->config); @@ -81,12 +80,6 @@ static int emitter_create(struct flb_rewrite_tag *ctx) return -1; } - /* Retrieve the collector id registered on the in_emitter initialization */ - coll_fd = in_emitter_get_collector_id(ins); - - /* Initialize plugin collector (event callback) */ - flb_input_collector_start(coll_fd, ins); - #ifdef FLB_HAVE_METRICS /* Override Metrics title */ ret = flb_metrics_title(ctx->emitter_name, ins->metrics);