Merge pull request #1 from bmilekic/master

Bugfix in example code

Author: edenhill

examples/rdkafka_example.c

@@ -34,6 +34,7 @@
 
 #include <ctype.h>
 #include <signal.h>
+#include <string.h>
 
 /* Typical include path would be <librdkafka/rdkafkah>, but this program
  * is builtin from within the librdkafka source tree and thus differs. */
@@ -133,7 +134,7 @@ int main (int argc, char **argv) {
 		/*
 		 * Producer
 		 */
-		char buf[1024];
+		char buf[2048];
 		int sendcnt = 0;
 
 		/* Create Kafka handle */
@@ -145,8 +146,11 @@ int main (int argc, char **argv) {
 		fprintf(stderr, "%% Type stuff and hit enter to send\n");
 		while (run && (fgets(buf, sizeof(buf), stdin))) {
 			int len = strlen(buf);
+			char *opbuf = malloc(len + 1);
+			strncpy(opbuf, buf, len + 1);
+
 			/* Send/Produce message. */
-			rd_kafka_produce(rk, topic, partition, 0, buf, len);
+			rd_kafka_produce(rk, topic, partition, RD_KAFKA_OP_F_FREE, opbuf, len);
 			fprintf(stderr, "%% Sent %i bytes to topic "
 				"%s partition %i\n", len, topic, partition);
 			sendcnt++;