Any stream API for pulsar apps?

I did a 10 min google search for pulsar stream API, something comparable to kafka stream API. (https://kafka.apache.org/documentation/streams/) but I haven't been able to find any. Is there such thing exists? Or am I conceptually mistaken? -- -jun

Re: Embedded pulsar cluster?

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 imag

Build failed in Jenkins: pulsar-master #455

See Changes: [guosijie] Make Function port part of InstanceConfig (#1731) -- [...truncated 2.79 MB...] [INFO] Ign:2 http://deb.debian.org/debian stretch InRelease [INFO] Get:3

Re: Embedded pulsar cluster?

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

Embedded pulsar cluster?

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 i

Slack digest for #dev - 2018-05-04

2018-05-03 11:08:13 UTC - haphut: @haphut has joined the channel