Code

kafka: fix compilation for older versions of librdkafka
authorVincent Bernat <vincent@bernat.im>
Fri, 7 Nov 2014 14:51:58 +0000 (15:51 +0100)
committerVincent Bernat <vincent@bernat.im>
Fri, 7 Nov 2014 14:51:58 +0000 (15:51 +0100)
Since commit f505691270f2317291c372fd5f004a4ffbce9f9a, kafka module was
broken. Enable definition of `kafka_log()` when using kafka logger
callback as well.

src/write_kafka.c

index 3e683c8432c1911f381a9f3e67deeba48c1aff99..ba76d71f6c727e4f1b19a5514e74e1e6eb36926e 100644 (file)
@@ -61,7 +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 *);
 
-#ifdef HAVE_LIBRDKAFKA_LOGGER
+#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,