There is a need to capture events and publish them into sns.

Aws sns client will be used, so implementation should be really similar to the existing kinesis sink