tl;dr -

aws_kinesis_random_partition_key

should be modified to create a random partition key for each record