Build ML Enhanced Event Streaming Apps with Python Microservices
summary
Apache Pulsar is shown scaling elastically with decoupled storage and compute, 8 data centers full‑mesh geo replication, and a thriving community (600+ contributors, 7k Slack members, 10k commits, 1k+ organizations). The Python client plus Pulsar Functions (Python) run a live sentiment pipeline: web UI → websocket → topic → Python function → output topic, demonstrating built‑in schema registry, Kafka protocol handler, tiered S3 offload, and working end‑to‑end examples with NiFi and Docker.
AI-written summary · about
chapters (13)
- 0:00ML enhanced event streaming intro
- 1:56Apache Pulsar architecture
- 9:15Pulsar ecosystem support
- 11:42Pulsar Functions processing
- 14:06Python client setup
- 17:43Schema management in Pulsar
- 20:16MQTT WebSocket for ML
- 22:00Kafka compatibility
- 23:23DevOps deployment
- 24:46Real-time ML app demo
- 27:11Streaming data in web apps
- 28:55Data flows with Apache NiFi
- 30:43Community resources
related talks
28mCloud Native Apache Pulsar Development 101 with Python
27mBuild ML Enhanced Event Streaming Apps with Java Microservices
51mEvent Streaming and Processing with Apache Pulsar
22mBuilding FinTech Streaming Applications with Pulsar
46mApache Pulsar: Finally an Alternative to Kafka?
45mApache Pulsar: Finally an Alternative to Kafka?
50mApache Pulsar 101: architecture and features
10mA tour of Apache Pulsar
