The current AWSKinesisStreamListener interface only exposes records coming from a single stream. Leave the stream filtering to the client to give more flexibility.

The stream filtering should happen in the job configuration. Leaving it to the client will allow to have a single AWSKinesisStreamListener implementation per client and filter by a stream in each job.