conduktor.io ↗

KIP-408 — Add Asynchronous Processing To Kafka Streams

Discussion Streams

Proposes adding an asynchronous processing model to Kafka Streams where a single stream task can offload work to a thread pool without blocking the poll loop. Addresses the performance bottleneck and ordering constraint that currently prevents full CPU utilization when record processing is I/O- or compute-bound.

Details

AuthorRichard Yu
StatusDiscussion
JIRAKAFKA-6989
WikiView on Apache Wiki
Created2018-12-18
Last Modified2019-01-06
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.