К содержимому
learnspaceYOUR NEXT CHAPTER
ПРОСТРАНСТВО ОБУЧЕНИЯ
ГлавнаяКаталог курсовМоё обучениеCoursera

Знания без границ

Учитесь у лучших университетов и компаний мира.

Открыть Coursera
Интеграция
Пространство университета
Моё пространствоСтраница курса
↵
ЯЛичный кабинетСтудент
© 2026 LearnSpaceКаждый день — возможность узнать больше.Помощь
Kafka Streams API for Developers Using Java/Spring Boot 3.X · LearnSpace
Назад в каталог
courseraПрограммирование

Kafka Streams API for Developers Using Java/Spring Boot 3.X

Курс от Packt
Средний≈ 25.2 чАнглийский
О курсеНавыкиПрограммаПреподаватели

О курсе

Updated in May 2025. This course now features Coursera Coach! A smarter way to learn with interactive, real-time conversations that help you test your knowledge, challenge assumptions, and deepen your understanding as you progress through the course. This course is meticulously crafted to guide you through the intricacies of Kafka Streams API using Java and Spring Boot 3.x. You’ll start by getting familiar with the core concepts of Kafka Streams, understanding how to build basic stream processing applications, and moving quickly into practical examples. The course structure ensures that you not only grasp the theoretical aspects but also gain hands-on experience by developing real-world applications such as an Order Management System. As you progress, you'll delve into more advanced topics, including serialization/deserialization, stateful operations like aggregation, joins, and windowing. You'll learn how to manage and query state stores interactively, handle errors efficiently, and test your Kafka Streams applications using TopologyTestDriver and JUnit5. The course emphasizes best practices and recommended approaches, ensuring that your applications are both scalable and maintainable. By the end of this course, you'll have a deep understanding of Kafka Streams API, be proficient in using Spring Boot for building and running Kafka Streams applications, and be well-prepared to tackle complex, real-time data processing challenges in your projects. Whether you're building microservices or handling big data pipelines, this course will elevate your expertise in distributed systems. This course is designed for Java developers with intermediate knowledge of Spring Boot. A basic understanding of Kafka and distributed systems will be beneficial but is not mandatory.

Навыки, которые вы освоите

Apache KafkaSpring BootReal Time DataScalabilityJavaJUnitUnit TestingData PipelinesRestful APIIntegration Testing

Программа курса

33 модулей · 171 учебных материалов

01Getting Started with the Course3 материалов

Getting Started with the Course

Course IntroductionВидеоFull Course ResourcesЧтениеPrerequisitesВидео
02Getting Started with Kafka Streams4 материалов

Getting Started with Kafka Streams

Учитесь у экспертов

Packt - Course Instructors

Преподаватель курса

Kafka Streams API for Developers Using Java/Spring Boot 3.X
В каталоге вашей программы

Инвестируйте в себя

Новые знания — в удобное для вас время.

Начать на Coursera

Обучение откроется на Coursera
в новой вкладке

Обучение на Coursera

≈ 25.2 ч

33 модулей

Язык: Английский

Субтитры: Казахский

Часть программы вашего университета
Introduction to Kafka StreamsВидео
Kafka Streams Terminologies - Topology and ProcessorВидео
Introduction to KStreams APIВидео
Understanding Kafka Streams APIDIALOGUE
03Greetings Kafka Streams App Using KStreams API7 материалов

Greetings Kafka Streams App Using KStreams API

Overview of the Greetings AppВидеоSet Up the Greetings AppВидеоTopology of the Greetings AppВидеоBuild the Kafka Streams Launcher ApplicationВидеоSetting Up Kafka Environment and Testing Our Greeting AppВидеоBuilding a Simple Kafka Streams ApplicationDIALOGUEAssessment 1Задание
04Operators in Kafka Streams Using KStreams API6 материалов

Operators in Kafka Streams Using KStreams API

Filter and FilterNotВидеоMap/MapValuesВидеоFlatMapValues/FlatMapВидеоpeekВидеоmergeВидеоMastering Kafka Stream FiltersDIALOGUE
05Serialization and Deserialization in Kafka Streams5 материалов

Serialization and Deserialization in Kafka Streams

How Key/Value Serialization and Deserialization Works in Kafka StreamsВидеоProviding Default Serializer/Deserializer Using Application ConfigurationВидеоBuild Custom Serdes for Enhanced Greeting MessagesВидеоUsage of Custom Serde in the Greeting AppВидеоUnderstanding Kafka Serialization and DeserializationDIALOGUE
06Reusable Generic Serializer/Deserializer (Recommended Approach)4 материалов

Reusable Generic Serializer/Deserializer (Recommended Approach)

Build a Generic Serializer/DeserializerВидеоIntegrate Generic Serializer/Deserializer into the Greeting AppВидеоBuilding a Generic Serializer and DeserializerDIALOGUEAssessment 2Задание
07Order Management Kafka Streams Application - A Real-Time Use Case5 материалов

Order Management Kafka Streams Application - A Real-Time Use Case

Overview of the Retail AppВидеоBuild the Topology for the Orders Management AppВидеоSplit the Restaurant/Retail Shopping Orders - Using Split and Branch OperatorВидеоTransform the Order Domain to a Revenue Domain TypeВидеоBuilding a Kafka Streams ApplicationDIALOGUE
08Topology, Stream, and Tasks - Under the Hood3 материалов

Topology, Stream, and Tasks - Under the Hood

Internals of Topology, Stream, and TasksВидеоExplore the Behavior of Streams by Modifying the Stream ThreadsВидеоUnderstanding Kafka Streams Topology and ParallelismDIALOGUE
09Error/Exception Handling in Kafka Streams8 материалов

Error/Exception Handling in Kafka Streams

Failures in Kafka StreamsВидеоDefault Deserialization Error BehaviorВидеоCustom Deserialization Error HandlerВидеоDefault and Custom Processor Error HandlerВидеоCustom Production Error HandlerВидеоError Handling When Kafka Cluster Is DownВидеоHandling Errors in Kafka Streams ApplicationsDIALOGUEAssessment 3Задание
10KTable and Global KTable5 материалов

KTable and Global KTable

Introduction to KTable APIВидеоBuild a Topology for KTableВидеоKTable - Under the HoodВидеоGlobalKTableВидеоExploring KTable in Kafka StreamsDIALOGUE
11StateFul Operations in Kafka Streams - Aggregate, Join, and Windowing Events7 материалов

StateFul Operations in Kafka Streams - Aggregate, Join, and Windowing Events

StateFul Operations in Kafka StreamsВидеоWhat Is Aggregation and How It Works?ВидеоAggregation Using "count" OperatorВидеоAggregation Using "reduce" OperatorВидеоAggregation Using "aggregate" OperatorВидеоUsing Materialized Store for count and reduce OperatorsВидеоUnderstanding Stateful Operations in Kafka StreamsDIALOGUE
12StateFul Operation Results - How to Access Them?3 материалов

StateFul Operation Results - How to Access Them?

How to Access the Results of AggregationВидеоExposing Aggregated Data with REST API and KafkaDIALOGUEAssessment 4Задание
13Aggregation in Order Management Application - A Real-Time Use Case3 материалов

Aggregation in Order Management Application - A Real-Time Use Case

Total Number of Orders by Each Store Using "count" OperatorВидеоTotal Revenue by Each Store Using "aggregate" OperatorВидеоImplementing Aggregations in Apache Kafka StreamsDIALOGUE
14Rekeying Kafka Records for Stateful Operations3 материалов

Rekeying Kafka Records for Stateful Operations

Effect of null Key in Stateful Operations and Repartition of Kafka RecordsВидеоRekeying Using the "selectKey" OperatorВидеоRekeying Kafka Records with Null KeysDIALOGUE
15StateFul Operations in Kafka Streams - Join11 материалов

StateFul Operations in Kafka Streams - Join

Introduction to Joins and Types of Joins in Kafka StreamsВидеоExplore innerJoin Using "join" Operator - Joining KStream and KTableВидеоExplore innerJoin Using "join" Operator - Joining KStream and GlobalKTableВидеоExplore innerJoin Using "join" Operator - Joining KTable and KTableВидеоExplore innerJoin Using "join" Operator - Joining KStream and KStreamВидеоJoining Kafka Streams Using "leftJoin" OperatorВидеоJoining Kafka Streams Using "outerJoin" OperatorВидеоJoin - Under the HoodВидеоCo-Partitioning Requirements in JoinsВидеоUnderstanding Kafka Stream JoinsDIALOGUEAssessment 5Задание
16Join in Order Management Application - A Real-Time Use Case2 материалов

Join in Order Management Application - A Real-Time Use Case

Join Aggregate Revenue with StoreDetails KTableВидеоImplementing Joins in Kafka StreamsDIALOGUE
17StateFul Operations in Kafka Streams - Windowing6 материалов

StateFul Operations in Kafka Streams - Windowing

Introduction to Windowing and Time ConceptsВидеоWindowing in Kafka Streams - Tumbling WindowsВидеоControl Emission of Windowed Results Using "suppress" OperatorВидеоWindowing in Kafka Streams - Hopping WindowsВидеоWindowing in Kafka Streams - Sliding WindowsВидеоUnderstanding Kafka Streams WindowingDIALOGUE
18Widowing in Order Management Application - A Real-Time Use Case7 материалов

Widowing in Order Management Application - A Real-Time Use Case

New Requirements for the Order Management ApplicationВидеоImplementing a CustomTimeStamp ExtractorВидеоAggregate "Number of Orders" by WindowsВидеоAggregate Revenue by WindowsВидеоJoins on the Windowed DataВидеоUnderstanding Window Functions in Stream ProcessingDIALOGUEAssessment 6Задание
19Behavior of Records with Future and Older Timestamp in Windowing2 материалов

Behavior of Records with Future and Older Timestamp in Windowing

Records with Timestamps before and after the CurrentTimestampВидеоHandling Timestamps in Kafka StreamsDIALOGUE
20Build Kafka Streams Application Using Spring Boot6 материалов

Build Kafka Streams Application Using Spring Boot

Introduction to Spring Boot and Kafka StreamsВидеоSet Up the Project - Greeting Streams App Using Spring Kafka StreamsВидеоConfiguring the Kafka Stream Using application.ymlВидеоBuild the Greeting TopologyВидеоTest Greeting App in LocalВидеоBuilding a Kafka Streams Application with SpringbootDIALOGUE
21Spring Boot Autoconfiguration of Kafka Streams3 материалов

Spring Boot Autoconfiguration of Kafka Streams

Internals of Autoconfiguring Kafka Streams in Spring BootВидеоUnderstanding Spring Boot Kafka Streams Auto-ConfigurationDIALOGUEAssessment 7Задание
22JSON Serialization/Deserialization in Spring Kafka Streams3 материалов

JSON Serialization/Deserialization in Spring Kafka Streams

JSON Serialization/Deserialization Using JsonSerdeВидеоJsonSerde Using Custom ObjectMapperВидеоWorking with Custom JSON Messages in Spring BootDIALOGUE
23Error Handling in Spring Kafka Streams6 материалов

Error Handling in Spring Kafka Streams

Handle Deserialization Error - Approach 1ВидеоHandle Deserialization Error Using Custom Error Handler - Approach 2ВидеоHandle Deserialization Errors Using Spring Specific Approach- Approach 3ВидеоHandle Uncaught Exceptions in the TopologyВидеоHandle Production ErrorsВидеоHandling Exceptions in Kafka Streams with Spring BootDIALOGUE
24Build Orders Kafka Streams Application Using Spring Boot4 материалов

Build Orders Kafka Streams Application Using Spring Boot

Set Up the Base Project for Orders Kafka Streams AppВидеоCreate the OrdersTopologyВидеоBuilding a Kafka Streams Application Using Spring BootDIALOGUEAssessment 8Задание
25Interactive Queries - Querying State Stores Using RESTFUL APIs7 материалов

Interactive Queries - Querying State Stores Using RESTFUL APIs

Build a GET Endpoint to Retrieve the OrderCount by OrderType - Part 1ВидеоBuild a GET Endpoint to Retrieve the OrderCount by OrderType - Part 2ВидеоRetrieve OrderCount by OrderType and LocationIdВидеоBuild a GET Endpoint to Retrieve the OrderCount for All OrderTypesВидеоBuild a GET Endpoint to Retrieve the Revenue by OrderTypeВидеоGlobal Error Handling for Useful Client Error MessagesВидеоBuilding REST APIs with Kafka StreamsDIALOGUE
26Interactive Queries - Querying Window State Stores Using RESTFUL APIs5 материалов

Interactive Queries - Querying Window State Stores Using RESTFUL APIs

Build a GET Endpoint to Retrieve OrderCount by OrderTypeВидеоBuild a GET Endpoint to Retrieve the Windowed OrderCount for All OrderTypesВидеоBuild a GET Endpoint to Retrieve the Windowed OrderCount within a Time RangeВидеоBuild a GET Endpoint to Retrieve the Revenue by OrderTypeВидеоQuerying Windowed State Stores in Spring BootDIALOGUE
27Testing Kafka Streams Using TopologyTestDriver and JUnit510 материалов

Testing Kafka Streams Using TopologyTestDriver and JUnit5

Testing Kafka Streams Using TopologyTestDriverВидеоUnit Testing Greetings App - Writing Data to a Output TopicВидеоUnit Testing Greetings App - Testing Multiple MessagesВидеоUnit Testing Greetings App - Error ScenarioВидеоUnit Testing OrdersCount - Writing Data to a State StoreВидеоUnit Testing OrdersRevenue - Writing Data to a State StoreВидеоUnit Testing OrdersRevenue by Windows - Writing Data to a State StoreВидеоLimitations of TopologyTestDriverВидеоTesting with Kafka StreamsDIALOGUEAssessment 9Задание
28Testing Kafka Streams in Spring Boot Using TopologyTestDriver and JUnit52 материалов

Testing Kafka Streams in Spring Boot Using TopologyTestDriver and JUnit5

Unit Test Using TopologyTestDriver in Spring BootВидеоTesting Topologies in Spring Boot with the Topology Test DriverDIALOGUE
29Integration Testing Spring KafkaStreams App Using @EmbeddedKafka5 материалов

Integration Testing Spring KafkaStreams App Using @EmbeddedKafka

Introduction and Set Up Integration TestВидеоIntegration Test for OrdersCountВидеоIntegration Test for OrdersRevenueВидеоIntegration Test for OrdersRevenue By WindowsВидеоWriting and Running Kafka Integration Tests with Spring BootDIALOGUE
30Grace Period in Kafka Streams3 материалов

Grace Period in Kafka Streams

Grace Period in WindowingВидеоUnderstanding Grace Periods in Kafka StreamsDIALOGUEAssessment 10Задание
31Build and Package the Spring Boot App as an Executable2 материалов

Build and Package the Spring Boot App as an Executable

Package the Spring Boot App and Execute It as a Jar FileВидеоBuilding and Running Java Executables with Spring BootDIALOGUE
32Exactly Once Processing/Semantics in Kafka Streams5 материалов

Exactly Once Processing/Semantics in Kafka Streams

What Is Exactly Once Processing and Why Is It Needed?ВидеоSet Up Exactly Once Processing in Kafka StreamsВидеоTransactions and Idempotent Producer - Under the HoodВидеоLimitations and Performance Impacts of Kafka TransactionsВидеоEnsuring Exactly Once Semantics in Kafka StreamsDIALOGUE
33Running Kafka Streams Applications as Multiple Instances (Spring Boot)16 материалов

Running Kafka Streams Applications as Multiple Instances (Spring Boot)

Running Kafka Streams Applications as Multiple InstancesВидеоSet Up to Run the Kafka Streams as Multiple InstancesВидеоKafka Streams MetadataВидеоAggregate Data from Multiple Instances - OverviewВидеоAggregate Data from Multiple Instances - Fetching Metadata - Part 1ВидеоAggregate Data from Multiple Instances - Building RestClients - Part 2ВидеоAggregate Data from Multiple Instances - Testing End to End - Part 3ВидеоKey-Based Queries with Multiple Instances - OverviewВидеоKey-Based Queries Multiple Instances - Fetching Metadata- Part 1ВидеоKey-Based Queries Multiple Instances - Building RestClient and Testing- Part 2ВидеоRefactor the Code for OrderCount for All OrderTypes Endpoint - /v1/orders/countВидеоFix the Test CasesВидеоWhat about the Other Endpoints?ВидеоAssessment 11ЗаданиеFull Course Practice AssessmentЗаданиеFull Course AssessmentЗадание