Added worker and kinesis consumer