-
Book Overview & Buying
-
Table Of Contents
Kafka Streams API for Developers Using Java/Spring Boot 3.X
By :
Kafka Streams API for Developers Using Java/Spring Boot 3.X
By:
Overview of this book
Welcome to the Kafka Streams API video course, where you will dive deep into building powerful Kafka Streams applications. In the first section, you will start by introducing the fundamental concepts and terminologies associated with Kafka Streams development. You will then move on to building a simple Kafka Streams app and testing it locally to gain hands-on experience.
Next, you will explore the various operators available in the Kafka Streams API, gaining a solid understanding of how they contribute to building robust streaming applications. You will also delve into the serialization and deserialization process, learning the best approach to creating a generic serializer and deserializer that can be utilized for any type of message.
Moving forward, you will take on the exciting task of implementing an order management system for a retail company using Kafka Streams. You will explore error handling mechanisms, KTable and GlobalKTable concepts, and dive into stateful operators and aggregation-related functionalities. Additionally, you will learn about the importance of rekeying records and the use of joins in your application.
Continuing your journey, you will learn about writing automated tests for Kafka Streams apps, including unit tests and integration tests using Embedded Kafka. Additionally, you will explore the concept of a grace period and its application in Kafka Streams.
Finally, you will learn how to package your Kafka Streams app as an executable and launch it effectively.
By the end of this course, you will have a comprehensive understanding of the Kafka Streams API, enabling you to build a wide range of applications using this powerful tool.
Table of Contents (33 chapters)
Getting Started with the Course
Getting Started with Kafka Streams
Greetings Kafka Streams App Using KStreams API
Operators in Kafka Streams Using KStreams API
Serialization and Deserialization in Kafka Streams
Reusable Generic Serializer/Deserializer (Recommended Approach)
Order Management Kafka Streams Application - A Real-Time Use Case
Topology, Stream, and Tasks - Under the Hood
Error/Exception Handling in Kafka Streams
KTable and Global KTable
StateFul Operations in Kafka Streams - Aggregate, Join, and Windowing Events
StateFul Operation Results - How to Access Them?
Aggregation in Order Management Application - A Real-Time Use Case
Rekeying Kafka Records for Stateful Operations
StateFul Operations in Kafka Streams - Join
Join in Order Management Application - A Real-Time Use Case
StateFul Operations in Kafka Streams - Windowing
Widowing in Order Management Application - A Real-Time Use Case
Behavior of Records with Future and Older Timestamp in Windowing
Build Kafka Streams Application Using Spring Boot
Spring Boot Autoconfiguration of Kafka Streams
JSON Serialization/Deserialization in Spring Kafka Streams
Error Handling in Spring Kafka Streams
Build Orders Kafka Streams Application Using Spring Boot
Interactive Queries - Querying State Stores Using RESTFUL APIs
Interactive Queries - Querying Window State Stores Using RESTFUL APIs
Testing Kafka Streams Using TopologyTestDriver and JUnit5
Testing Kafka Streams in Spring Boot Using TopologyTestDriver and JUnit5
Integration Testing Spring KafkaStreams App Using @EmbeddedKafka
Grace Period in Kafka Streams
Build and Package the Spring Boot App as an Executable
Exactly Once Processing/Semantics in Kafka Streams
Running Kafka Streams Applications as Multiple Instances (Spring Boot)