Important
You are viewing documentation for an older version of Confluent Platform. For the latest, click here.
Kafka Streams¶
Kafka Streams is a client library for building applications and microservices, where the input and output data are stored in a Kafka cluster. It combines the simplicity of writing and deploying standard Java and Scala applications on the client side with the benefits of Kafka’s server-side cluster technology.
Getting started¶
Quick Start¶
The Quick Start demonstrates how to run your first Java application that uses the Kafka Streams library by showcasing a simple end-to-end data pipeline powered by Kafka.
Streams API Screencasts¶
Watch the Intro to Streams API on YouTube.
Contents¶
- Introduction
- Requirements
- Quick Start
- Concepts
- Architecture
- Code Examples
- Developer Guide
- Operations
- Upgrade Guide
- FAQ
- General
- Is Kafka Streams a project separate from Apache Kafka?
- Is Kafka Streams a proprietary library of Confluent?
- Do Kafka Streams applications run inside the Kafka brokers?
- What are the system dependencies of Kafka Streams?
- How do I migrate my Kafka Streams applications from CP 3.0.x and CP 3.1.x applications to CP 3.2.x
- Which versions of Kafka clusters are supported by Kafka Streams?
- What programming languages are supported?
- Scalability
- Processing
- Failure and exception handling
- Interactive Queries
- Security
- Troubleshooting and debugging
- Easier to interpret Java stacktraces?
- Visualizing topologies?
- Inspecting streams and tables?
- Invalid Timestamp Exception
- Why do I get an
IllegalStateException
when accessing record metadata? - Why is
punctuate()
not called? - Scala: compile error “no type parameter”, “Java-defined trait is invariant in type T”
- How can I convert a KStream to a KTable without an aggregation step?
- RocksDB behavior in 1-core environments
- General
- Javadocs