export const createKinesisClient = (conf: ClientConfig, endpoint?: string): Kinesis => {
  const instance = new Kinesis(conf || {})
  if (endpoint) {
    instance.setEndpoint(endpoint)
  }

  return instance
}

 return new Promise(function(resolve, reject) {
     Kinesis.putRecord(kinesisRequest, function (error: any, data: any) {
         if (error) return reject(error);
         console.log("Successfully put to ExactTargetStatus stream with SequenceNumber of " + data.SequenceNumber);
         return resolve(data);
     });
 })

  const next = done => {
    const params = {
      StreamName: stream,
      ExclusiveStartShardId: startShardId,
    }

    client.describeStream(params, (err, data) => {
      if (err) {
        return done(err)
      }

      if (!data.StreamDescription.HasMoreShards) {
        foundAllShards = true
      }

      const lastShard = data.StreamDescription.Shards[data.StreamDescription.Shards.length - 1]
      startShardId = lastShard.ShardId

      shards = shards.concat(data.StreamDescription.Shards)
      done()
    })
  }

 private describe(callback) {
   this.kinesis.describeStream({ StreamName: this.name }, callback)
 }