rdkafka_performance: Count immediate produce() failures as failed mes…

…sages too
confluentinc · Jan 1, 2014 · d25d782 · d25d782
1 parent 11b2bef
commit d25d782
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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;