X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fwrite_kafka.c;h=2baaf0e5f1b371dddea530e0acf7073211dad665;hb=849f5394cce97a76da080f6cd9e5194b7f4ee0f0;hp=b1c8bf94a2a716184797434e6c157ecf6fb6a2d3;hpb=be126043c2be20399d7670fe194645292018bde0;p=collectd.git diff --git a/src/write_kafka.c b/src/write_kafka.c index b1c8bf94..2baaf0e5 100644 --- a/src/write_kafka.c +++ b/src/write_kafka.c @@ -77,6 +77,14 @@ static void kafka_log(const rd_kafka_t *rkt, int level, const char *fac, } #endif +static rd_kafka_resp_err_t kafka_error() { +#if RD_KAFKA_VERSION >= 0x000b00ff + return rd_kafka_last_error(); +#else + return rd_kafka_errno2err(errno); +#endif +} + static uint32_t kafka_hash(const char *keydata, size_t keylen) { uint32_t hash = 5381; for (; keylen > 0; keylen--) @@ -147,7 +155,7 @@ static int kafka_handle(struct kafka_topic_context *ctx) /* {{{ */ if ((ctx->topic = rd_kafka_topic_new(ctx->kafka, ctx->topic_name, topic_conf)) == NULL) { ERROR("write_kafka plugin: cannot create topic : %s\n", - rd_kafka_err2str(rd_kafka_errno2err(errno))); + rd_kafka_err2str(kafka_error())); return errno; } @@ -399,7 +407,7 @@ static void kafka_config_topic(rd_kafka_conf_t *conf, rd_kafka_topic_conf_set_opaque(tctx->conf, tctx); snprintf(callback_name, sizeof(callback_name), "write_kafka/%s", - tctx->topic_name); + tctx->topic_name); status = plugin_register_write( callback_name, kafka_write,