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

When set to `0`, the producer does not wait for any acknowledgment from the broker.

When set to `1`, the producer waits for acknowledgment from the leader node.

When set to `all`, the producer waits for an acknowledgment from all in-sync replicas.

When set to `none`, the producer does not wait for any acknowledgment from the broker.

**(Select all that apply.)** Which is *true* about the `acks` configuration? 

(Select all that apply.) Which is true about the <code>acks</code> configuration?

**(True or False)** You can only use the partitioner implementations provided by Kafka.

(True or False) You can only use the partitioner implementations provided by Kafka.

If the produce operation fails, your application needs to have the ability to retry the operation. Which Producer API configuration  should you use in this case?

If the produce operation fails, your application needs to have the ability to retry the operation. Which Producer API configuration should you use in this case?

**(Select all that apply.)** Your application sends messages to Kafka, but the `send` operation times out frequently. Which configuration properties should you tune? 

(Select all that apply.) Your application sends messages to Kafka, but the <code>send</code> operation times out frequently. Which configuration properties should you tune?

When using the synchronous mode, the client application waits for a response from Kafka.

In asynchronous mode, the client application does not wait for a response from the Kafka cluster.

You can specify a callback function when using the synchronous mode.

You can use the `KafkaAsynchronousProducer` to asynchronously send messages to Kafka.

**(Select all that apply.)** Which statements are *true*? 

(Select all that apply.) Which statements are true?

Test your understanding of the Kafka Producer API.

Introduction

Apache Kafka Producer API

Apache Kafka Consumer API

Kafka Streams

Kafka Connect

Exploring Projects in the Kafka Ecosystem

Wrap Up

Final Project

Quiz: The Kafka Producer API