We will now learn how we can implement a Java lambda function that will be invoked when records are added to a Kinesis stream. I will not show all the details of provisioning the lambda. You can refer to earlier recipes (mentioned in the Getting ready section).