From d25d78228bf40e85a7b6d1b99d465678411b6f27 Mon Sep 17 00:00:00 2001 From: Magnus Edenhill Date: Wed, 1 Jan 2014 23:26:07 +0100 Subject: [PATCH] rdkafka_performance: Count immediate produce() failures as failed messages too --- examples/rdkafka_performance.c | 1 + 1 file changed, 1 insertion(+) diff --git a/examples/rdkafka_performance.c b/examples/rdkafka_performance.c index 37c3c11f1c..742eeadb0e 100644 --- a/examples/rdkafka_performance.c +++ b/examples/rdkafka_performance.c @@ -579,6 +579,7 @@ int main (int argc, char **argv) { strerror(errno), errno == ENOBUFS ? " (backpressure)":""); + msgs_failed++; cnt.tx_err++; if (errno != ENOBUFS) { run = 0;