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
| Author | Boyang Chen |
| Status | Accepted |
| Kafka Version | 2.3 |
| JIRA | KAFKA-8285 |
| Wiki | View on Apache Wiki |
| Created | 2019-04-25 |
| Last Modified | 2019-05-03 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.