remove offset object from consumer
test
put fetch request into a independent longpolling socket