write_sensu: fix format-string portability problem
[collectd.git] / src / write_kafka.c
index e1d2f12..ccc4784 100644 (file)
@@ -200,7 +200,7 @@ static void kafka_config_topic(rd_kafka_conf_t *conf, oconfig_item_t *ci) /* {{{
         return;
     }
 #ifdef HAVE_LIBRDKAFKA_LOGGER
-    rd_kafka_conf_set_logger(tctx->kafka, kafka_log);
+    rd_kafka_set_logger(tctx->kafka, kafka_log);
 #endif
     conf = NULL;
 
@@ -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) {