From: Pierre-Yves Ritschard Date: Mon, 18 Apr 2016 12:50:28 +0000 (+0200) Subject: write_kafka: do not call depreciated functions unless necessary X-Git-Tag: collectd-5.6.0~338^2 X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=refs%2Fpull%2F1672%2Fhead;p=thirdparty%2Fcollectd.git write_kafka: do not call depreciated functions unless necessary --- diff --git a/src/write_kafka.c b/src/write_kafka.c index a5371d4c0..2c3296db2 100644 --- a/src/write_kafka.c +++ b/src/write_kafka.c @@ -114,7 +114,8 @@ static int kafka_handle(struct kafka_topic_context *ctx) /* {{{ */ INFO ("write_kafka plugin: created KAFKA handle : %s", rd_kafka_name(ctx->kafka)); -#ifdef HAVE_LIBRDKAFKA_LOGGER +#if defined(HAVE_LIBRDKAFKA_LOGGER) && !defined(HAVE_LIBRDKAFKA_LOG_CB) + if rd_kafka_set_logger(ctx->kafka, kafka_log); #endif } @@ -469,4 +470,3 @@ void module_register(void) { plugin_register_complex_config ("write_kafka", kafka_config); } -