It's also trivially easy to extend this to Kinesis with a lambda.