write_kafka plugin: Topic property not being set

diff --git a/src/write_kafka.c b/src/write_kafka.c
index e1d2f1229a6684a340b4cf3da40b71f9a9ca09c4..a2947d15b34fc84eedac2332a315128bf6a27c6b 100644 (file)
--- 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) {