X-Git-Url: https://git.octo.it/?a=blobdiff_plain;ds=sidebyside;f=src%2Fwrite_kafka.c;fp=src%2Fwrite_kafka.c;h=09bb639ad30f350ecf042b80cf66431d1df0563b;hb=904a45ef1b06bf7b14238af6d2aeb9bce176daf7;hp=592d669a1bec5013b4c717d8c19d419d4fae54a7;hpb=0fce99de653c243e0597d25808275712048b9126;p=collectd.git diff --git a/src/write_kafka.c b/src/write_kafka.c index 592d669a..09bb639a 100644 --- a/src/write_kafka.c +++ b/src/write_kafka.c @@ -413,11 +413,11 @@ static void kafka_config_topic(rd_kafka_conf_t *conf, ssnprintf(callback_name, sizeof(callback_name), "write_kafka/%s", tctx->topic_name); - status = plugin_register_write( - callback_name, kafka_write, - &(user_data_t){ - .data = tctx, .free_func = kafka_topic_context_free, - }); + status = plugin_register_write(callback_name, kafka_write, + &(user_data_t){ + .data = tctx, + .free_func = kafka_topic_context_free, + }); if (status != 0) { WARNING("write_kafka plugin: plugin_register_write (\"%s\") " "failed with status %i.",