search

awslabs / kinesis-aggregation

AWS libraries/modules for working with Kinesis aggregated record data
Apache License 2.0
378 stars 153 forks source link

kinesis_publisher.py is not compatible with KCL #122

Open jnewbigin opened 3 years ago

jnewbigin commented 3 years ago

As described in https://github.com/awslabs/kinesis-aggregation/issues/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