kinesis_publisher.py is not compatible with KCL
Opened this issue · 0 comments
jnewbigin commented
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