X-Git-Url: https://git.octo.it/?p=collectd.git;a=blobdiff_plain;f=src%2Fwrite_kafka.c;h=3c573801c22823d992835585530d4b8afca3cb1e;hp=b1c8bf94a2a716184797434e6c157ecf6fb6a2d3;hb=e746ad785774de37a30302fef65f1c4aaf8698ab;hpb=f81a5a84d3d5fc941b624c28b1ab70971cc23ac9 diff --git a/src/write_kafka.c b/src/write_kafka.c index b1c8bf94..3c573801 100644 --- a/src/write_kafka.c +++ b/src/write_kafka.c @@ -399,7 +399,7 @@ static void kafka_config_topic(rd_kafka_conf_t *conf, rd_kafka_topic_conf_set_opaque(tctx->conf, tctx); snprintf(callback_name, sizeof(callback_name), "write_kafka/%s", - tctx->topic_name); + tctx->topic_name); status = plugin_register_write( callback_name, kafka_write,