From 225a1446eca7ec01da12b05f53fbe786942be869 Mon Sep 17 00:00:00 2001 From: ciomaire Date: Mon, 26 Jan 2015 14:02:11 +0100 Subject: [PATCH] write_kafka plugin: Topic property not being set --- src/write_kafka.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/write_kafka.c b/src/write_kafka.c index e1d2f122..a2947d15 100644 --- a/src/write_kafka.c +++ b/src/write_kafka.c @@ -245,7 +245,7 @@ static void kafka_config_topic(rd_kafka_conf_t *conf, oconfig_item_t *ci) /* {{{ goto errout; } key = child->values[0].value.string; - val = child->values[0].value.string; + val = child->values[1].value.string; ret = rd_kafka_topic_conf_set(tctx->conf,key, val, errbuf, sizeof(errbuf)); if (ret != RD_KAFKA_CONF_OK) { -- 2.11.0