Hey friends,

I would like to start discussion for a very small KIP:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-462%3A+Use+local+thread+id+for+KStreams

it is trying to avoid sharing thread-id increment between multiple stream 
instances configured in one JVM. This is an important fix for static 
membership<https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances>
 to be effective for KStreams in edge case like changing `group.instance.id` 
throughout restarts due to thread-id interleaving.

I will open the vote thread in the main while, since this is a very small fix. 
Feel free to continue the discussion on this thread, thank you!

Boyang

Reply via email to