From 0cf5df3dbcf508d419b52d3deecac9ba74b2e260 Mon Sep 17 00:00:00 2001 From: Marc Fournier Date: Tue, 14 Apr 2015 08:33:14 +0200 Subject: [PATCH] write_kafka: correct mistyped function name --- configure.ac | 2 +- src/write_kafka.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/configure.ac b/configure.ac index 5557b0bf..6a48b726 100644 --- 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 a2947d15..ccc4784e 100644 --- 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; -- 2.11.0