The Dream Stream Team for Pulsar and Spring
summary
A Spring Boot app polls a real air-quality REST API and produces JSON messages to Pulsar using Kafka, MQTT, AMQP and native Pulsar clients; a Java Pulsar Function parses the schema and routes pm2.5 / pm10 / ozone into separate topics while a simple WebSocket SPA consumes those topics. Uses a standalone Pulsar cluster on a laptop, schema registry, tiered S3 storage and geo-replication, and demonstrates that one Pulsar cluster handles Kafka MQTT AMQP and WebSocket protocols though the full demo stresses a small machine.
AI-written summary · about
chapters (14)
- 0:00Introduction
- 1:31Overview of Pulsar
- 2:58Spring and messaging
- 5:12Advanced messaging patterns
- 7:18Schemas and consumers
- 9:35Functions and connectors
- 12:05Protocol handlers
- 14:28Java and Spring development
- 17:25Architecture and connectivity
- 21:25Code demonstration
- 27:30Function routing and logic
- 30:44Performance and persistence
- 33:50Geo-replication and scale
- 37:04Q&A and closing
related talks
01h 44mData processing with Kafka Streams and Spring Framework.
01h 11mBootiful Stream Processing!
51mTransporting Data at Warp Speed: How to connect Spring Boot apps...
44mBootiful Spring Boot
51mBrewing the Best of All Worlds
46mAsyncAPI + Spring Cloud Stream = Event-Driven Microservices Made Easy
51mData processing with Kafka Streams and Spring Framework. Dmitriy Sergeev. Java Fest 2020 Online
54mReactive Spring