Added code for replaying kafka msgs from s3