conduktor.io ↗

KIP-276 — Add StreamsConfig prefix for different consumers

Accepted Kafka 2.0 StreamsConsumer

Adds main.consumer., restore.consumer., and global.consumer. config prefixes to StreamsConfig, allowing users to set different config values for each of Kafka Streams' three internal consumer clients. Streams previously used a single consumer. prefix shared by all three consumers, making it impossible to tune fetch sizes, session timeouts, or security settings independently for restore vs main consumption.

Details

AuthorBoyang Chen
StatusAccepted
Kafka Version2.0
JIRAKAFKA-6657
WikiView on Apache Wiki
Created2018-03-29
Last Modified2019-01-01
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.