My ruby is rusty, but based on line 257 in the fluentd kinesis forwarder code in method

build_records_array_to_put

it looks like they are using random partition key per batch (i could be wrong) https://github.com/awslabs/aws-fluent-plugin-kinesis/blob/master/lib/fluent/plugin/out_kinesis.rb