Łukasz Chrząszcz

Daily portion of beefy nerd knowledge

How to count events in Kafka Streams?

Stores and aggregation in Kafka Streams

Kafka Streams enables you to use stateful processing via Stores. Let's go through a simple example of order-counting app and discover how Stores fit in the stream processing world

How to use Kafka Streams to process events from one topic to another?

Introduction to Kafka Streams

Kafka Streams is a high-level client library for interacting with Kafka. How does it help to process events from topic to topic? What are the capabilities of this library? Join me and let's find out

What happens when a new consumer joins the group in Kafka?

Rebalancing in Apache Kafka

Ever wondered how Kafka manages rebalancing? How are partitions assigned? Let's find out!

What does the heartbeat thread do in Kafka Consumer?

Behavior of Kafka consumer's background thread

We will dig into the heartbeat thread code to discover what it does and how it communicates with the rest of the consumer.

What happens when you call poll on Kafka Consumer?

Internals of Kafka consumer initialization and first fetch

We will create a new consumer, subscribe to a topic and execute first poll, describing what happens step by step.

Kafka 101

Introduction to Apache Kafka

Let's explore Kafka basics. We will discover what it does, what problem does it solve, and we will explore simple message passing from producer to consumer.