X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fwrite_kafka.c;h=2c3296db221eda6cdd2a8223bca1113950f9d5c5;hb=1eaf573c8724b2b97d670863c0f8cb7afa9ecbf8;hp=a5371d4c0a933e40d3c2c9051babf5b39383909f;hpb=10ce782a86c7ac7d60ffac06bb59763c1708f395;p=collectd.git diff --git a/src/write_kafka.c b/src/write_kafka.c index a5371d4c..2c3296db 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); } -