Matteo, It was nice meeting your earlier and thank you for letting me those options. I am new so I can't picture what form of embedded/single class mini-pulsar cluster would be ideal for our unit tests yet, so I'd have to try them and get a feel of it first. I'm also looking into pulsar docker image and it seems I can quickly make up some local integration with our services. ( https://hub.docker.com/r/apachepulsar/pulsar/tags/)
On Fri, May 4, 2018 at 4:50 PM, Matteo Merli <matteo.me...@gmail.com> wrote: > Hi Jun, > > there are few options: > > 1. We have a MockedBrokerService that we use in our unit tests. It's not > super-fancy but it might work: > https://github.com/apache/incubator-pulsar/blob/master/ > pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/ > MockedPulsarServiceBaseTest.java > That starts a "real" broker instance with mocked ZooKeeper and > BookKeeper to keep data in memory. The way we typically use this is by > extending from that class and create tests. > > 2. There is a standalone Pulsar service ("bin/pulsar standalone") that > includes broker, ZK and BK service in a single JVM process. It uses the > "real" implementation of each component and stores the data on disk. It was > not initially meant to be embedded but it might actually very easy to fix. > > 3. There's a LocalBookkeeperEnsemble class that creates a ZK + BK service > and, combined with a PulsarService instance, could get the whole service > up. I agree that a single class "service" would be a nicer option. > > Matteo > > On Fri, May 4, 2018 at 12:55 PM jun aoki <ja...@apache.org> wrote: > > > 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 > > > -- > Matteo Merli > <mme...@apache.org> > -- -jun