A layer on top of poseidon-cluster for consuming kafka messages generated by emque-producing