X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fwrite_kafka.c;h=04e67b92fc82f407530e8fa088edf2e7ef38a40f;hb=711f5b6c86f51061c21bedcaa46214a01de0125c;hp=c120d15d9598bfdbabaa94701f696fbe07c45d0f;hpb=9b2d6a2792ef579fca5c03a2076c1e05f4b93507;p=collectd.git diff --git a/src/write_kafka.c b/src/write_kafka.c index c120d15d..04e67b92 100644 --- a/src/write_kafka.c +++ b/src/write_kafka.c @@ -383,6 +383,10 @@ static void kafka_config_topic(rd_kafka_conf_t *conf, status = cf_util_get_flag(child, &tctx->graphite_flags, GRAPHITE_PRESERVE_SEPARATOR); + } else if (strcasecmp("GraphiteUseTags", child->key) == 0) { + status = + cf_util_get_flag(child, &tctx->graphite_flags, GRAPHITE_USE_TAGS); + } else if (strcasecmp("GraphitePrefix", child->key) == 0) { status = cf_util_get_string(child, &tctx->prefix); } else if (strcasecmp("GraphitePostfix", child->key) == 0) {