Merge pull request #81 from julien-lecomte/patch-1

producer/consumer typo/inversion
edenhill · Dec 9, 2016 · 0a2dd68 · 0a2dd68
2 parents 20a02ef + 701496f
commit 0a2dd68
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafkacat.c b/kafkacat.c
@@ -490,7 +490,7 @@ static void kafkaconsumer_run (FILE *fp, char *const *topics, int topic_cnt) {
         /* Create consumer */
         if (!(conf.rk = rd_kafka_new(RD_KAFKA_CONSUMER, conf.rk_conf,
                                      errstr, sizeof(errstr))))
-                FATAL("Failed to create producer: %s", errstr);
+                FATAL("Failed to create consumer: %s", errstr);
         conf.rk_conf  = NULL;
 
         /* Forward main event queue to consumer queue so we can