correct size for binary data while consuming

Author: David Wieland

kafka.c

@@ -1220,7 +1220,13 @@ int kafka_consume(rd_kafka_t *r, zval* return_value, char* topic, char* offset,
                 //ensure there is a payload
                 char payload[(int) rkmessage_return->len];
                 sprintf(payload, "%.*s", (int) rkmessage_return->len, (char *) rkmessage_return->payload);
-                add_index_string(return_value, (int) rkmessage_return->offset, payload, 1);
+                add_index_stringl(
+                    return_value,
+                    (int) rkmessage_return->offset,
+                    payload,
+                    (int) rkmessage_return->len,
+                    1
+                );
             }
             else
             {