X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fwrite_kafka.c;h=592d669a1bec5013b4c717d8c19d419d4fae54a7;hb=06d8ab31ff97b30d601e8f8a942bedc339825042;hp=4decc4e4208f6a60657852de37a46df5009f047d;hpb=8f6aa6970bf787e6a11e095322af3338ec781d78;p=collectd.git diff --git a/src/write_kafka.c b/src/write_kafka.c index 4decc4e4..592d669a 100644 --- a/src/write_kafka.c +++ b/src/write_kafka.c @@ -411,7 +411,7 @@ static void kafka_config_topic(rd_kafka_conf_t *conf, rd_kafka_topic_conf_set_opaque(tctx->conf, tctx); ssnprintf(callback_name, sizeof(callback_name), "write_kafka/%s", - tctx->topic_name); + tctx->topic_name); status = plugin_register_write( callback_name, kafka_write,