Apache Kafka® Event Streaming Platform For Kotlin Developers

This talk will give you a quick overview of Kafka, the event streaming platform. You will see its internal architecture, including how it partitions messaging workloads in a fault-tolerant way and how it provides message durability. You'll learn about Kafka's approach to pub/sub messaging and how Kotlin developers can leverage a framework for handling streamed data.

0:00 Introduction
2:56 Bootstrapping the project
8:23 Building the application
9:56 Implementing a supplier
11:34 Configuration
13:59 Confluent cloud
17:37 Demo
18:40 TestContainers
19:40 Exploring Kafka topics
21:38 Implementing a consumer
26:18 How does it work?
33:48 Consumer groups
35:15 Stream processing
52:50 Querying data
1:02:47 Summary

Speakers
Developer Advocate at Confluent, makers of an event streaming platform based on Apache Kafka.
Viktor has extensive experience in building low-latency, scalable, and highly available distributed systems. He is a professional conference speaker on distributed systems, streaming data, JVM, and DevOps topics, and is a regular at events including JavaOne, Devoxx, OSCON, QCon, and others. Сo-author of O’Reilly’s “Enterprise Web Development.”

[JetBrainsTV]

0:00 Introduction
2:56 Bootstrapping the project
8:23 Building the application
9:56 Implementing a supplier
11:34 Configuration
13:59 Confluent cloud
17:37 Demo
18:40 TestContainers
19:40 Exploring Kafka topics
21:38 Implementing a consumer
26:18 How does it work?
33:48 Consumer groups
35:15 Stream processing
52:50 Querying data
1:02:47 Summary

[realdanielpeach]

Thank GOODNESS they figured out that audio. When he fixed it to broken lol…

[RajeshSamson]

In your application.yaml you are writing a binder like this
bindings:
producerChuckNoris-out-0

What's the significance of the zero? Is it the number of arguments passed to the producerChuckNoris method? And, I also wanted to know how to pass the class type instead of String.

[ViktorGamov]

Question about docker images:


Progress bar

[havefuntrading]

I was hoping to see some usage of coroutines and how they can be combined with Kafka. The demo was still good but it would not differ that much if you had used Java instead of Kotlin.

[mehulbisht]

so is Ktor related / better than spring?

[realdanielpeach]

My project is not connecting to confluent for some reason. No messages are being produced. Not sure what i missed

[gabormiklay]

Haha. I've seen already. I mean the results. 😁

[pixelPlex]

Recorded volume level for the video is too low. The issues come from Viktor's microphone volume level being way too low. Anton's microphone volume level is set at a high enough level to be heard clearly.

[t]

Is the source code for this demo available somewhere?

[gabormiklay]

Good luck to understand the lot of out of context lines. 🤭

Also: put them onto the correct timeline. 😱