Sample project which shows how you can use partition keys to trigger a lambda for specific user records when kinesis aggregation is applied manually - View it on GitHub