Set the PartitionKey when publishing records

[tomharvey]

I'm guessing that this TODO means this isn't yet implemented?

async-kinesis/kinesis/producer.py

Line 271 in d07efb2

# todo: custom partition key

Any thoughts or blockers on how this might be implemented or is that open to the community?

[hampsterx]

hi sorry for late reply.

OutputItem = namedtuple("OutputItem", ["size", "n", "data"])

those are the items being fed to the producer, I guess would need to add partitionKey and then add a second arg to put() of the producer.

I can have a crack later in the week~

[hampsterx]

just realised one issue with implementing this is most of the processors are aggregating the records into batches (eg KPLAggregator, NewLineAggregator, etc).

awslabs/amazon-kinesis-producer#130

Seems like other approach is a batch method. eg put_records(batch, key) I guess that makes more sense.

[tomharvey]

It's not super important right now. Hopefully I can help out when it becomes so for me :)