KAFKA-14010: AlterPartition request won't retry when receiving retriable error (#12329)
When submitting the AlterIsr request, we register a future listener to handle the response. When receiving retriable error, we expected the AlterIsr request will get retried. And then, we'll re-submit the request again. However, before the future listener got called, we didn't clear the `unsentIsrUpdates`, which causes we failed to "enqueue" the request because we thought there's an in-flight request. We use "try/finally" to make sure the unsentIsrUpdates got cleared, but it happened "after" we retry the request Reviewers: David Jacot <djacot@confluent.io>, dengziming <dengziming1993@gmail.com>
显示
- core/src/main/scala/kafka/cluster/Partition.scala 1 个添加, 1 个删除core/src/main/scala/kafka/cluster/Partition.scala
- core/src/main/scala/kafka/server/AlterPartitionManager.scala 6 个添加, 8 个删除core/src/main/scala/kafka/server/AlterPartitionManager.scala
- core/src/test/scala/unit/kafka/cluster/PartitionTest.scala 105 个添加, 2 个删除core/src/test/scala/unit/kafka/cluster/PartitionTest.scala
- core/src/test/scala/unit/kafka/server/AlterPartitionManagerTest.scala 82 个添加, 20 个删除...t/scala/unit/kafka/server/AlterPartitionManagerTest.scala
加载中
想要评论请 注册 或 登录