X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fwrite_kafka.c;h=ba76d71f6c727e4f1b19a5514e74e1e6eb36926e;hb=28f4914d1727c7a5a0dbace945c3b1fadbb0bc91;hp=2149ff1818a00d392069a93e00d5f7b85c1363e6;hpb=af0b3263a683a6cdec6303c8e2594bfcd58f49ca;p=collectd.git diff --git a/src/write_kafka.c b/src/write_kafka.c index 2149ff18..ba76d71f 100644 --- a/src/write_kafka.c +++ b/src/write_kafka.c @@ -61,6 +61,7 @@ static int kafka_write(const data_set_t *, const value_list_t *, user_data_t *); static int32_t kafka_partition(const rd_kafka_topic_t *, const void *, size_t, int32_t, void *, void *); +#if defined HAVE_LIBRDKAFKA_LOGGER || defined HAVE_LIBRDKAFKA_LOG_CB static void kafka_log(const rd_kafka_t *, int, const char *, const char *); static void kafka_log(const rd_kafka_t *rkt, int level, @@ -68,6 +69,7 @@ static void kafka_log(const rd_kafka_t *rkt, int level, { plugin_log(level, "%s", msg); } +#endif static int32_t kafka_partition(const rd_kafka_topic_t *rkt, const void *keydata, size_t keylen,