Change I/F to process records by a bucket
done UT
Add created_at field into bucket record to use in leo_gateway