write_kafka: correct mistyped function name

diff --git a/configure.ac b/configure.ac
index 5557b0b..6a48b72 100644 (file)
--- a/configure.ac
+++ b/configure.ac
@@ -3742,7 +3742,7 @@ if test "x$with_librdkafka" = "xyes"
 then
        AC_CHECK_LIB(rdkafka, rd_kafka_new, [with_librdkafka="yes"], [with_librdkafka="no (Symbol 'rd_kafka_new' not found)"])
   AC_CHECK_LIB(rdkafka, rd_kafka_conf_set_log_cb, [with_librdkafka_log_cb="yes"], [with_librdkafka_log_cb="no"])
-  AC_CHECK_LIB(rdkafka, rd_kafka_conf_set_logger, [with_librdkafka_logger="yes"], [with_librdkafka_logger="no"])
+  AC_CHECK_LIB(rdkafka, rd_kafka_set_logger, [with_librdkafka_logger="yes"], [with_librdkafka_logger="no"])
 fi
 if test "x$with_librdkafka" = "xyes"
 then

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;