[GitHub] [kafka] hachikuji commented on a change in pull request #11733: KAFKA-13587; Implement leader recovery for KIP-704

hachikuji commented on a change in pull request #11733: URL: https://github.com/apache/kafka/pull/11733#discussion_r814304074 ## File path: metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java ## @@ -760,44 +719,132 @@ BrokersToIsrs brokersToIsrs()

[GitHub] [kafka] hachikuji commented on a change in pull request #11733: KAFKA-13587; Implement leader recovery for KIP-704

hachikuji commented on a change in pull request #11733: URL: https://github.com/apache/kafka/pull/11733#discussion_r813188764 ## File path: core/src/test/scala/unit/kafka/cluster/PartitionTest.scala ## @@ -1077,6 +1078,58 @@ class PartitionTest extends AbstractPartitionTest {

[GitHub] [kafka] hachikuji commented on a change in pull request #11733: KAFKA-13587; Implement leader recovery for KIP-704

hachikuji commented on a change in pull request #11733: URL: https://github.com/apache/kafka/pull/11733#discussion_r813163349 ## File path: clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java ## @@ -110,6 +110,14 @@ LIST_TRANSACTIONS(ApiMessageType.LIST_TRA

[GitHub] [kafka] hachikuji commented on a change in pull request #11733: KAFKA-13587; Implement leader recovery for KIP-704

hachikuji commented on a change in pull request #11733: URL: https://github.com/apache/kafka/pull/11733#discussion_r813161823 ## File path: core/src/main/scala/kafka/server/AlterIsrManager.scala ## @@ -250,23 +260,35 @@ class DefaultAlterIsrManager( val partitionRespon

[GitHub] [kafka] hachikuji commented on a change in pull request #11733: KAFKA-13587; Implement leader recovery for KIP-704

hachikuji commented on a change in pull request #11733: URL: https://github.com/apache/kafka/pull/11733#discussion_r803180976 ## File path: clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java ## @@ -110,6 +110,14 @@ LIST_TRANSACTIONS(ApiMessageType.LIST_TRA