0% completed

All LessonsFree Lessons (4)

Kafka Streams Overview

Introduction to the Course Introduction to Kafka Streams Kafka Streams Topologies Kafka Streams Hello World Quiz: Basic Kafka Streams Concepts

Building Our Kafka Tool Belt

First Steps with Kafka Scripts

Consuming and Producing Messages

Consuming and Producing Messages with Keys

Kafka Topic as a Log

Kafka Topic Partitions

Kafka Topic Partitions in Practice

Consumer Groups

The kafka-consumer-groups Command

What’s in Our Kafka Tool Belt: A Summary

Quiz: Kafka Concepts and Commands

Stateless Processing

Stateless Processing Introduction Setting Up the Project Serialization and Deserialization Filtering Branching Streams Mapping Flat Mapping Merging and Adding a Sink Node Testing Kafka Streams Topologies Quiz: Stateless Processing

Error Handling

Error Handling in Kafka Streams: Overview Deserialization Error Handling Processor Error Handling Quiz: Error Handling

Stateful Processing

Stateful Processing Basic Concepts Kafka Streams Stateful Operations Windowing: Tumbling and Hopping Windows Windowing: Sliding and Session Windows Interactive Queries Interactive Queries: Remote Queries Quiz: Stateful Processing

Project

Setting up a Streaming Data Pipeline With Kafka

Kafka Streams with Spring Boot

Spring Boot: Motivation and Overview Classic Integration: Project Setup Classic Integration: Topology and State Store Spring Cloud Stream: Setup and Configuration Spring Cloud Stream: Topology and State Store Kafka Streams Monitoring and Metrics with Spring Boot Kafka Streams Topology Visualization Quiz: Kafka Streams with Spring Boot

Mini Project

Build an Order Processing Kafka Streams Application

Wrap Up

Kafka Streams for Software Developers/

...

/

Quiz: Kafka Concepts and Commands

Quiz: Kafka Concepts and Commands

Test your knowledge of building a Kafka tool belt.

We'll cover the following...

Technical Quiz

1.

Which flag would you use if you wanted to read the entire contents of a topic?

A.

--from-the-start

B.

--from-beginning

C.

--everything

D.

No flag is needed, this is the default behavior

1 / 6

...