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
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  
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