do you guys have embedded pulsar I can use for unit tests? Something similar embedded kafka to https://github.com/apache/kafka/blob/trunk/streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java
I'd like to play with pulsar by replacing our kafka stream app with it. -- -jun
