~/talk

Deep Dive into Building Streaming Applications with Apache Pulsar

slides:none on file

Claims Apache Pulsar can replace multiple messaging systems by running a standalone Docker cluster or Kubernetes, separating compute and storage and handling messaging and event streaming in one platform. Languages and tools shown: Java, Go, Python, Apache NiFi, Pulsar Functions, Sinks/Sources, Pulsar SQL, Flink SQL, Spark SQL. Live demo ingests Raspberry Pi sensor JSON, runs a function to clean/enrich, writes to a Delta Lake sink, queries with Flink continuous SQL and pushes results to a WebSocket UI — it works. Native Kafka protocol handler and tiered S3 storage are used.

AI-written summary · about

  1. 0:00Start
  2. 6:02Connectivity
  3. 10:52Schema Registry
  4. 17:02Pulsar Functions
  5. 18:42Building Tenant, Namespace, Topics
  6. 20:42Install Python 3 Pulsar Client
  7. 22:31Example Avro Schema Usage
  8. 25:02Websockets
  9. 27:52Setting Subscription Type Java
  10. 28:59Producing Object Events From Java
  11. 30:10Use Cases
~/search
type to search 6,249 conferences, 138,987 speakers and 185,172 talks
~/help
cmdctrl k
search every conference, speaker and series
/
focus the filter search
h
home
c
conferences
s
speakers
e
series
t
light / dark — the status bar button does the same
?
this help
esc
close this, then clear every filter — or just the search, while you are typing in it

Ignored while you are typing. Pages without a filter rail have no search to focus.