Sub-pages:
Internal Data Management
Application Reset Tool
Data (Re)Processing Scenarios
Join Semantics
Development Plan
Discussions
Find more links about Kafka Streams at
Kafka Ecosystem
page.
Kafka Streams related KIPs:
KIP-28: Add a processor client
KIP-32: Add timestamps to Kafka message
KIP-62: Allow consumer to send heartbeats from a background thread
KIP-63: Unify store and downstream caching in streams
KIP-67: Queryable state for Kafka Streams
KIP-71: Enable log compaction and deletion to co-exist
KIP-77: Improve Kafka Streams Join Semantics
KIP-90: Remove zkClient dependency from Streams
KIP-93: Improve invalid timestamp handling in Kafka Streams
KIP-94: Session Windows
KIP-95: Incremental Batch Processing for Kafka Streams
KIP-97: Improved Kafka Client RPC Compatibility Policy
KIP-99: Add Global Tables to Kafka Streams
KIP-100: Relax Type constraints in Kafka Streams API
KIP-104: Granular Sensors for Streams
KIP-114: KTable materialization and improved semantics
KIP-116: Add State Store Checkpoint Interval Configuration
KIP-120: Cleanup Kafka Streams builder API
KIP-121: Add KStream peek method
KIP-123: Allow per stream/table timestamp extracto
r