refactor logic to get messages from consumer to method and return messages when creating consumer
refactor logic to get messages from consumer to method and return messages when creating consumer

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