Streams Developer Guide

Developer guide for building, configuring, testing, and running Kafka Streams applications.

Guide to writing Kafka Streams applications with the DSL and Processor API.

Kafka Streams application configuration options and runtime settings.

Kafka Streams DSL API for defining stream processing logic.

Kafka Streams Processor API for low-level stream processing.

Kafka Streams DSL operator naming for stable topology upgrades.

Kafka Streams data types, serialization, and SerDes.

Guide to testing Kafka Streams applications.

Kafka Streams interactive queries for local and remote state stores.

Kafka Streams memory management for caches, state stores, and record buffers.

Guide to running and scaling Kafka Streams applications.

Kafka Streams user and internal topic management and configuration.

Security configuration and required ACLs for Kafka Streams applications.

Kafka Streams application reset tool usage and limitations.

Kafka Streams rebalance protocol behavior, migration paths, and limitations.

Kafka Streams groups tool for inspecting and managing streams groups.

Broker-side plugin for recording and exposing the processing topology of streams groups.

Migration guidance from the Kafka Streams Scala API to the Java API.