transform the message before emitting and send a subscribed event when set up.
transform the message before emitting and send a subscribed event when set up.

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