move subscription to consumer message emit to just after init to ensure no messages missed
move subscription to consumer message emit to just after init to ensure no messages missed

wenisman/kafka-http-proxy,hoppity/kafka-http-proxy