write_kafka: correct mistyped function name

[collectd.git] / src / write_kafka.c

diff --git a/src/write_kafka.c b/src/write_kafka.c
index a2947d1..ccc4784 100644 (file)
--- a/src/write_kafka.c
+++ b/src/write_kafka.c
@@ -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;