Learn Apache Kafka in a practical/hands-on manner.

build.tar.gz

producer-sync-example

producer-async-example

part1-dsl-api-stateful-ops

part2-dsl-api-stateful-ops

part3-dsl-api-stateful-ops

interactive-queries

testing-kafka-streams

spring-kafka

spring-kafka-consumer

consumer-api-example

queue-topic-example

consumer-api-config-example

kafka-connect-transformations-example

kafka-connect-sink-example

kafka-connect-source-example

kafka-schema-registry-example

Apache Kafka is a distributed streaming platform designed to handle real-time data streaming and processing in a distributed and fault-tolerant manner. This course can be taken by software developers and data engineers wanting to learn Kafka to build data-intensive applications. 

You will begin with an introduction to the Kafka architecture, client libraries, and its project ecosystem. Next, you will learn to use the Kafka Client APIs along with key configurations. Then, you will learn to develop stream processing applications using Kafka Streams. You will also explore the Kafka Connect Source and Sink connectors. You will finish by learning to make Kafka-related projects in addition to the core ecosystem. 

After completing this course, you will be comfortable with developing data-intensive applications. The course will prove helpful for anyone who wants to learn Kafka using a practical, hands-on approach for building real-time data streaming, event-driven architecture, microservices, and log aggregation.

Mastering Apache Kafka

**(True or False)** The Kafka Streams Processor API is a high-level API that allows developers to build stream processing applications using a fluent, easy-to-use syntax.

(True or False) The Kafka Streams Processor API is a high-level API that allows developers to build stream processing applications using a fluent, easy-to-use syntax.

Which Kafka Streams operation should you use to transform the values of each record in a stream?

Which Kafka Streams operation should you use to transform the values of each record in a stream?

**(True or False)** You must execute `groupByKey` or `groupBy` before the aggregation operation in Kafka Streams.

(True or False) You must execute <code>groupByKey</code> or <code>groupBy</code> before the aggregation operation in Kafka Streams.

You want to analyze user behavior by grouping a stream of user page view events and taking into account the period of user inactivity. Which Kafka Streams windowing operation should you use?

You want to analyze user behavior by grouping a stream of user page view events and taking into account the period of user inactivity. Which Kafka Streams windowing operation should you use?

**(True or False)** You can only use the REST API-based RPC layer to access the Kafka Streams state store data using Interactive Queries.

(True or False) You can only use the REST API-based RPC layer to access the Kafka Streams state store data using Interactive Queries.

Which method should be used to write data to a mock Kafka topic represented by `TestInputTopic`?

Which method should be used to write data to a mock Kafka topic represented by <code>TestInputTopic</code>?

Which method should be used to read data from a mock Kafka topic represented by `TestOutputTopic`?

Which method should be used to read data from a mock Kafka topic represented by <code>TestOutputTopic</code>?

Test your understanding of Kafka Streams.

Introduction

Apache Kafka Producer API

Apache Kafka Consumer API

Kafka Streams

Kafka Connect

Exploring Projects in the Kafka Ecosystem

Wrap Up

Final Project

Quiz: Kafka Streams