I think to implement this task you have to use Confluent platform for kafka. It allows you to connect aws connector in your platform. But to create this environment, it may take some time. So you can use docker to implement this task easily. Go through the bellow links, it will give idea to you.
To install confluent platform.
To implement using docker.