function kafka_produce_batch calls incorrect lib function rd_kafka_produce. It should call rd_kafka_produce_batch. Tested successfully.

cslinuxboy · cslinuxboy · commit 88bb7ac62673 · 2015-06-26T12:44:29.000-06:00
diff --git a/kafka.c b/kafka.c
@@ -502,7 +502,7 @@ int kafka_produce_batch(rd_kafka_t *r, char *topic, char **msg, int *msg_len, in
             messages[i].payload = msg[i];
             messages[i].len = msg_len[i];
         }
-        i = rd_kafka_produce(rkt, partition, RD_KAFKA_MSG_F_COPY, messages, msg_cnt, NULL, 0, opaque);
+        i = rd_kafka_produce_batch(rkt, partition, RD_KAFKA_MSG_F_COPY, messages, msg_cnt);
         if (i < msg_cnt)
         {
             if (log_level)

Original file line number	Diff line number	Diff line change
`@@ -502,7 +502,7 @@ int kafka_produce_batch(rd_kafka_t r, char topic, char *msg, int msg_len, in`
`502`	`502`	`messages[i].payload = msg[i];`
`503`	`503`	`messages[i].len = msg_len[i];`
`504`	`504`	`}`
`505`		`- i = rd_kafka_produce(rkt, partition, RD_KAFKA_MSG_F_COPY, messages, msg_cnt, NULL, 0, opaque);`
	`505`	`+ i = rd_kafka_produce_batch(rkt, partition, RD_KAFKA_MSG_F_COPY, messages, msg_cnt);`
`506`	`506`	`if (i < msg_cnt)`
`507`	`507`	`{`
`508`	`508`	`if (log_level)`