use our own consumer (kafka-node one is no good)