diff --git a/lib/stream/leo-stream.js b/lib/stream/leo-stream.js
index 8d082dff..d6c94b4e 100644
--- a/lib/stream/leo-stream.js
+++ b/lib/stream/leo-stream.js
@@ -9,6 +9,7 @@ var PassThrough = require('stream').PassThrough;
 var moment = require("moment");
 var async = require("async");
 
+
 var backoff = require("backoff");
 var extend = require("extend");
 
@@ -635,11 +636,18 @@ module.exports = function(configure) {
 					logger.time("kinesis request");
 					kinesis.putRecords({
 						Records: records.map((r) => {
-							return {
+							let randomhashkey = 0
+							if(!opts.partitionHashKey) {
+								randomhashkey = moment().valueOf()
+							}
+							let ret = {
 								Data: r,
-								PartitionKey: "0",
-								ExplicitHashKey: (opts.partitionHashKey || 0).toString()
-							};
+								PartitionKey: randomhashkey.toString()
+							} 
+							if(opts.partitionHashKey) {
+								ret.ExplicitHashKey = opts.partitionHashKey.toString()
+							}
+							return ret
 						}),
 						StreamName: configure.stream
 					}, function(err, data) {