Title: Kafka Streams  
Author: Matthias J. Sax Aug 08, 2016
Last Changed by: Matthias J. Sax Apr 12, 2024
Tiny Link: (useful for email) https://cwiki.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
Labels
There are no labels assigned to this page.
Recent Changes
Time Editor  
Apr 12, 2024 16:18 Matthias J. Sax View Changes
Apr 07, 2024 15:28 Nicholas Telford View Changes
Add KIP-1035: StateStore managed changelog offsets
Apr 02, 2024 14:43 Matthias J. Sax View Changes
Mar 31, 2024 10:00 Matthias J. Sax View Changes
Mar 09, 2024 03:28 Matthias J. Sax  
Outgoing Links
External Links (7)
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-698%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 (67)     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-1027: Add MockFixedKeyProcessorContext
    Page: KIP-1034: Dead letter queue in Kafka Streams
    Page: KIP-328: Ability to suppress updates for KTables
    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-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-95: Incremental Batch Processing for Kafka Streams
    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-1035: StateStore managed changelog offsets
    Page: KIP-796: Interactive Query v2
    Page: KIP-669: Preserve Source Partition in Kafka Streams from context
    Page: KIP-260: add primary join operation for Stream-Stream join (WIP)
    Page: FAQ
    Page: KIP-924: customizable task assignment for Streams
    Page: KIP-362: Support dynamic gap session window
    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-1033: Add Kafka Streams exception handler for exceptions occurring during processing
    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-560: Auto infer external topic partitions in stream reset tool
    Page: KIP-816: Topology changes without local state reset
    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