KAFKA-2406: Throttle ISR propagation#114
Conversation
|
kafka-trunk-git-pr #88 FAILURE |
|
kafka-trunk-git-pr #89 SUCCESS |
There was a problem hiding this comment.
To do this, we need to hold a controller lock since sendUpdateMetadataRequest() is not thread safe.
|
kafka-trunk-git-pr #102 SUCCESS |
There was a problem hiding this comment.
I thought that you also wanted to move the code that creates the isr_change path in ZK to the beginning of broker startup (currently it's in the controller startup)?
There was a problem hiding this comment.
Yes, I did that in another patch. I can put it in this patch to save a separate commit :)
|
kafka-trunk-git-pr #116 SUCCESS |
There was a problem hiding this comment.
This method is probably no longer needed.
|
kafka-trunk-git-pr #119 SUCCESS |
…terval value for now and keep KIP-29 open for discussion to see if we want to expose a config. There will be a follow up patch after we reach conclusion in KIP-29.
|
kafka-trunk-git-pr #128 SUCCESS |
|
Thanks for the latest patch. LGTM. |
This is the first cut to enable integration of client and broker code for the Idempotent producer.
This is the first cut to enable integration of client and broker code for the Idempotent producer.
This is the first cut to enable integration of client and broker code for the Idempotent producer.
This is a follow up patch for KAFKA-2406. Further test to verify if this change alone is enough to solve the problem or not.