Deep Dive into Building Streaming Applications with Apache Pulsar
Talkat CloudOpen @ Open Source Summit Europe 2022 · on Friday, 2022-09-16· at 10:50· Wicklow Hall 2B (Level 2), Convention Centre Dublin, Spencer Dock, N Wall Quay, North Wall Dublin 1, D01 T1·
summary
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
chapters (11)
- 0:00Start
- 6:02Connectivity
- 10:52Schema Registry
- 17:02Pulsar Functions
- 18:42Building Tenant, Namespace, Topics
- 20:42Install Python 3 Pulsar Client
- 22:31Example Avro Schema Usage
- 25:02Websockets
- 27:52Setting Subscription Type Java
- 28:59Producing Object Events From Java
- 30:10Use Cases
related talks
35mStreaming Data Made Easy
48mApache Pulsar: Event Streaming in The Cloud Native World
34mEvent Streaming in the Cloud Native World with Apache Pulsar
59mEvent Streaming and Processing Using Apache Pulsar
55mEvent Messaging and Streaming with Apache Pulsar
14mFast Data on-Ramp with Apache Pulsar on K8
48mEvent Streaming and Processing using Apache Pulsar and Apache Pinot.
30mCreating a Data Fabric for IoT
