Apache Pulsar Tutorial with Scala

Written form:

In this video, we'll learn Apache Pulsar, a new toolkit built for VERY high throughput (hundreds of BILLIONS of messages per day) and a growing competitor for Apache Kafka. We'll see

- how to set up a Pulsar Docker container
- how to generate events (using a fictitious set of IoT sensors)
- how to send events to Pulsar
- how to subscribe to Pulsar topics in a variety of ways
- how to read/receive events from Pulsar

Follow Rock the JVM on:

-------------------------------------------------------------------------
-------------------------------------------------------------------------

[hatrixyesa]

Love this video and very interested in Apache Pulsar. If you build a series on Pulsar that would be great to watch as a paid subscriber. Also, highly interested in Geo-Replication demo with this much detail for Pulsar and Scala.

[chinmaybendigeri]

How would you use the pulsar client python library with pyspark without using spark APIs and run it on spark cluster ?

[ВоиныСвета-гм]

Is it possible(good idea) to use Pulsar with effect libraries like Cats, ZIO?

[LonnerCro]

Amazing as always!
I was wondering why did you use a dedicated fixed thread pool for the producer instead of just using the global ExecutionContext. Is the pulsar library blocking for sendAsync publishs too?

[arnoldtuber]

It does not work on my M1 with
"io.netty" % % "4.1.97.Final" classifier "osx-aarch_64"
I see error message:
WARNING: Can not find in the classpath, fallback to system defaults. This may result in incorrect DNS resolutions on MacOS. Check whether you have a dependency on