DIY: Data streaming platform with Kafka and Java
summary
Shows a runnable DIY streaming stack built with Docker Compose, Apache Kafka, Java clients and Kafka Connect, plus a JDBC connector and optional schema registry. Demo code generates a telescope feed into a telescope_feed topic, joins it with a celestial_metadata topic using Kafka Streams global table to split into planet/star/asteroid/alien topics, and exposes pitfalls: accidental typos creating missing topics, default auto-commit=true losing messages, and needing external configs for serializers and offsets. The pipeline runs in the demo but exposes fragile config and connector failures.
AI-written summary · about
chapters (8)
- 0:00Introduction
- 1:08What is Kafka
- 3:14Platform design principles
- 8:13Kafka setup with Docker
- 16:17Java producer implementation
- 19:51Kafka streams processor
- 27:16Data splitting and branching
- 29:48Summary and use cases
related talks
53mApache Kafka and KSQL in Action : Lets Build a Streaming Data Pipeline!
43mApache Kafka and KSQL in Action: Let’s Build a Streaming Data Pipeline!
03h 00mStream Processing, Going Beyond Pub/Sub with Kafka Streams and...
39mAnalysing Public Kafka Data from NASA Satellites
39mKafka as a Platform: The Ecosystem from the Ground Up
01h 00mIn Depth Kafka Streams
21mStreaming DataFrames: A New Way to Process Streaming Data
41mKafka as a Platform: The Ecosystem from the Ground Up
