Added fetch_earliest_offset to kafka consumer to be able to reread from start of que