THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Log in
Skip to sidebar
Skip to main content
Apache Software Foundation
Spaces
Hit enter to search
Help
Online Help
Keyboard Shortcuts
Feed Builder
What’s new
What’s new
Available Gadgets
About Confluence
Log in
Apache Kafka
Pages
Blog
Space shortcuts
Retrospectives
Child pages
Index
Kafka Streams
DSL Optimizer
Kafka Streams Application Reset Tool
Kafka Streams Architecture
Kafka Streams Data (Re)Processing Scenarios
Kafka Streams Development Plan
Kafka Streams Discussions
Kafka Streams DSL Grammar
Kafka Streams Internal Data Management
Kafka Streams Join Semantics
Kafka Streams KIP Overview
Kafka Stream Usage Patterns
Streams Runtime Architecture with New Threading
9 more child pages
Browse pages
Configure
Space tools
View Page
A
t
tachments (0)
Page History
Page Information
View in Hierarchy
View Source
Delete comments
Export to PDF
Export to Word
Copy Page Tree
Pages
Index
Kafka Streams
Page Information
Title:
Kafka Streams
Author:
Matthias Sax
Aug 08, 2016
Last Changed by:
Matthias Sax
Dec 11, 2023
Tiny Link:
(useful for email)
https://cwiki-test.apache.org/confluence/x/0ATtAw
Export As:
Word
·
PDF
Incoming Links
Apache Kafka (3)
Page:
Kafka Improvement Proposals
Page:
Ecosystem
Page:
Kafka Streams KIP Overview
Hierarchy
Parent Page
Home page:
Index
Children (12)
Page:
DSL Optimizer
Page:
Kafka Streams Application Reset Tool
Page:
Kafka Streams Architecture
Page:
Kafka Streams Data (Re)Processing Scenarios
Page:
Kafka Streams Development Plan
Page:
Kafka Streams Discussions
Page:
Kafka Streams DSL Grammar
Page:
Kafka Streams Internal Data Management
Page:
Kafka Streams Join Semantics
Page:
Kafka Streams KIP Overview
Show all...
Page:
Kafka Stream Usage Patterns
Page:
Streams Runtime Architecture with New Threading
Hide...
Labels
There are no labels assigned to this page.
Recent Changes
Time
Editor
Dec 11, 2023 09:49
Matthias Sax
View Changes
Dec 09, 2023 08:18
Florin Akermann
View Changes
Dec 06, 2023 16:14
Matthias Sax
View Changes
Dec 06, 2023 16:01
Matthias Sax
View Changes
Nov 30, 2023 20:17
Matthias Sax
View Page History
Outgoing Links
External Links (9)
https://cwiki.apache.org/confluence/display/KAFKA/KIP-698%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-992%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-985%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-948%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-149%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-718%3…
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Imp…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-677%3…
kafka.apache.org/documentation/streams/
Apache Kafka (71)
Page:
KIP-969: Support range interactive queries (IQv2) for versioned state stores
Page:
KIP-216: IQ should throw different exceptions for different errors
Page:
KIP-314: KTable to GlobalKTable Bi-directional Join
Page:
KIP-463: Auto-configure non-default Serdes passed alongside the TopologyBuilder
Page:
Kafka Streams Architecture
Page:
KIP-408: Add Asynchronous Processing To Kafka Streams
Page:
KIP-645: Replace Windows with a proper interface
Page:
KIP-955: Add stream-table join on foreign key
Page:
KIP-557: Add emit on change support for Kafka Streams
Page:
KIP-326: Schedulable KTable as Graph source
Page:
KIP-878: Internal Topic Autoscaling for Kafka Streams
Page:
KIP-667: Remove deprecated methods from ReadOnlyWindowStore
Page:
Kafka Streams Join Semantics
Page:
KIP-675: Convert KTable to a KStream using the previous value
Page:
KIP-747 Add support for basic aggregation APIs
Page:
KIP-328: Ability to suppress updates for KTables
Page:
KIP-844: Transactional State Stores
Page:
KIP-647: Add ability to handle late messages in streams-aggregation
Page:
Kafka Streams Data (Re)Processing Scenarios
Page:
KIP-655: Windowed Distinct Operation for Kafka Streams API
Page:
KIP-258: Allow to Store Record Timestamps in RocksDB
Page:
KIP-962: Relax non-null key requirement in Kafka Streams
Page:
KIP-634: Complementary support for headers and record metadata in Kafka Streams DSL
Page:
Kafka Streams Discussions
Page:
KIP-311: Async processing with dynamic scheduling in Kafka Streams
Page:
KIP-XXX: [Streams] Support multiple topic resolution in TopicNameExtractor
Page:
KIP-997: update WindowRangeQuery and unify WindowKeyQuery and WindowRangeQuery
Page:
KIP-406: GlobalStreamThread should honor custom reset policy
Page:
KIP-513: Distinguish between Key and Value serdes in scala wrapper library for kafka streams
Page:
KIP-925: Rack aware task assignment in Kafka Streams
Page:
KIP-95: Incremental Batch Processing for Kafka Streams
Page:
KIP-968: Support single-key_multi-timestamp interactive queries (IQv2) for versioned state stores
Page:
KIP-892: Transactional Semantics for StateStores
Page:
KIP-819: Merge multiple KStreams in one operation
Page:
KIP-300: Add Windowed KTable API in StreamsBuilder
Page:
KIP-989: RocksDB Iterator Metrics
Page:
KIP-540: Implement per key stream time tracking
Page:
KIP-796: Interactive Query v2
Page:
KIP-669: Preserve Source Partition in Kafka Streams from context
Page:
KIP-988: Streams Standby Update Listener
Page:
KIP-260: add primary join operation for Stream-Stream join (WIP)
Page:
FAQ
Page:
KIP-362: Support dynamic gap session window
Page:
KIP-960: Support single-key_single-timestamp interactive queries (IQv2) for versioned state stores
Page:
KIP-674: Metric Reporter to Aggregate Metrics in Kafka Streams
Page:
Kafka Streams DSL Grammar
Page:
KIP-869: Improve Streams State Restoration Visibility
Page:
Ecosystem
Page:
Kafka Stream Usage Patterns
Page:
Kafka Streams Development Plan
Page:
DSL Optimizer
Page:
KIP-813: Shareable State Stores
Page:
KIP-807: Refactor KafkaStreams exposed metadata hierarchy
Page:
KIP-439: Cleanup built-in Store interfaces
Page:
KIP-508: Make Suppression State Queriable
Page:
KIP-857: Streaming recursion in Kafka Streams
Page:
KIP-759: Unneeded repartition canceling
Page:
KIP-424: Allow suppression of intermediate events based on wall clock time
Page:
KIP-159: Introducing Rich functions to Streams
Page:
KIP-954: expand default DSL store configuration to custom types
Page:
KIP-714: Client metrics and observability
Page:
KIP-560: Auto infer external topic partitions in stream reset tool
Page:
KIP-816: Topology changes without local state reset
Page:
KIP-990: Capability to PAUSE Tasks on DeserializationException
Page:
KIP-335: Consider configurations for KafkaStreams
Page:
KIP-457: Add DISCONNECTED status to Kafka Streams
Page:
Kafka Streams Application Reset Tool
Page:
Streams Runtime Architecture with New Threading
Page:
KIP-448: Add State Stores Unit Test Support to Kafka Streams Test Utils
Page:
Kafka Streams KIP Overview
Page:
Kafka Streams Internal Data Management
Overview
Content Tools
Apps
{"serverDuration": 136, "requestCorrelationId": "db844e978e52004b"}