awslabs/kinesis-aggregation

kinesis_publisher.py is not compatible with KCL

Opened this issue · 0 comments

As described in #11
The partition key should be the same for every user record in a kinesis record
kinesis_publisher.py creates a new value for each user record.

As a result, only one user record will be returned by the KCL :-(

I have made a change to the example which should fix that