kafka isr维护

kafka ISR（In Sync Replica）是一种机制，用于确保在kafka集群中不会丢失消息。ISR是由leader维护的一组与其保持同步的replica副本。每个partition都有一个ISR集合，其中至少有一个存活的replica。保持ISR集合存活并且消息成功提交是确保kafka不丢失消息的关键。

在kafka 0.9.0.0版本之后，引入了一种更好的ISR维护方法。在此版本中，使用了参数replica.lag.time.max.ms来代替之前的replica.lag.max.messages。该参数表示允许follower副本在多长时间内不同步消息。只要在指定的时间范围内，follower有同步消息，就认为该follower处于ISR中。这样就避免了生产者一次发送大量消息到leader副本导致ISR频繁收缩和扩张的问题。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* [Kafka ISR机制](https://blog.csdn.net/qq_19734597/article/details/119154221)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 50%"]
- *3* [Kafka ISR 副本同步机制](https://blog.csdn.net/zchdjb/article/details/102927475)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 50%"]
[ .reference_list ]