conduktor.io ↗

KIP-462 — Use local thread id for KStreams

Accepted Kafka 2.3 StreamsConsumer

Changes Kafka Streams thread IDs to use a JVM-local thread counter rather than a shared static counter across multiple KafkaStreams instances in the same JVM, ensuring stable and unique group.instance.id values for static membership. Multiple KafkaStreams instances in one JVM shared a static thread counter, causing thread IDs to be non-deterministic across restarts when instances initialized concurrently, breaking static membership semantics.

Details

AuthorBoyang Chen
StatusAccepted
Kafka Version2.3
JIRAKAFKA-8285
WikiView on Apache Wiki
Created2019-04-25
Last Modified2019-05-03
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.