Code

write_kafka: correct mistyped function name
authorMarc Fournier <marc.fournier@camptocamp.com>
Tue, 14 Apr 2015 06:33:14 +0000 (08:33 +0200)
committerMarc Fournier <marc.fournier@camptocamp.com>
Tue, 14 Apr 2015 07:24:47 +0000 (09:24 +0200)
configure.ac
src/write_kafka.c

index 5557b0bf8b09152940a640e4b5c812a95c37a907..6a48b72642a358367e40907c51582f1ebbce8c0c 100644 (file)
@@ -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
index a2947d15b34fc84eedac2332a315128bf6a27c6b..ccc4784e66351bc2cb5285f95afe9f70697d43de 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;