~/talk

DIY: Data streaming platform with Kafka and Java

Talkat Heapcon 2022 · 2022-11-03..11-04· [data-engineering]
links:none on file
slides:none on file

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

  1. 0:00Introduction
  2. 1:08What is Kafka
  3. 3:14Platform design principles
  4. 8:13Kafka setup with Docker
  5. 16:17Java producer implementation
  6. 19:51Kafka streams processor
  7. 27:16Data splitting and branching
  8. 29:48Summary and use 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.