summary | shortlog | log | commit | commitdiff | tree
raw | patch | inline | side by side (parent: 9c7c25a)
raw | patch | inline | side by side (parent: 9c7c25a)
author | Vincent Bernat <vincent@bernat.im> | |
Fri, 7 Nov 2014 14:51:58 +0000 (15:51 +0100) | ||
committer | Vincent 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.
broken. Enable definition of `kafka_log()` when using kafka logger
callback as well.
src/write_kafka.c | patch | blob | history |
diff --git a/src/write_kafka.c b/src/write_kafka.c
index 3e683c8432c1911f381a9f3e67deeba48c1aff99..ba76d71f6c727e4f1b19a5514e74e1e6eb36926e 100644 (file)
--- a/src/write_kafka.c
+++ b/src/write_kafka.c
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,