X-Git-Url: https://git.octo.it/?a=blobdiff_plain;ds=sidebyside;f=src%2Fwrite_kafka.c;h=a719cd376d18a5cd6fb690117133977ddfff13fd;hb=0a8741b9061f8df4a78a448c021612db06e17425;hp=6018fea05502f511a1ed8794f9f11982810e1a82;hpb=df3252cafd38f005595e682f4494dd991496140c;p=collectd.git diff --git a/src/write_kafka.c b/src/write_kafka.c index 6018fea0..a719cd37 100644 --- a/src/write_kafka.c +++ b/src/write_kafka.c @@ -376,6 +376,10 @@ static void kafka_config_topic(rd_kafka_conf_t *conf, oconfig_item_t *ci) /* {{{ status = cf_util_get_flag (child, &tctx->graphite_flags, GRAPHITE_ALWAYS_APPEND_DS); + } else if (strcasecmp ("GraphitePreserveSeparator", child->key) == 0) { + status = cf_util_get_flag (child, &tctx->graphite_flags, + GRAPHITE_PRESERVE_SEPARATOR); + } else if (strcasecmp ("GraphitePrefix", child->key) == 0) { status = cf_util_get_string (child, &tctx->prefix); } else if (strcasecmp ("GraphitePostfix", child->key) == 0) {