You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "黃竣陽 (Jira)" <ji...@apache.org> on 2025/12/29 16:20:00 UTC
[jira] [Assigned] (KAFKA-20023) Fix kafka-reassign-partitions.sh to handle dead brokers
[ https://issues.apache.org/jira/browse/KAFKA-20023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
黃竣陽 reassigned KAFKA-20023:
---------------------------
Assignee: 黃竣陽
> Fix kafka-reassign-partitions.sh to handle dead brokers
> --------------------------------------------------------
>
> Key: KAFKA-20023
> URL: https://issues.apache.org/jira/browse/KAFKA-20023
> Project: Kafka
> Issue Type: Bug
> Reporter: Andrew Grant
> Assignee: 黃竣陽
> Priority: Major
>
> In https://issues.apache.org/jira/browse/KAFKA-19582 we added code to print the log directories of the replicas in the current assignment. But if the current assignment contains a dead broker, then the command will fail including when running with --execute. The error you will see is
> {code:java}
> Error: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: describeReplicaLogDirs
> java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: describeReplicaLogDirs
> at java.base/java.util.concurrent.CompletableFuture.wrapInExecutionException(CompletableFuture.java:347)
> at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:442)
> at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2119)
> at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:155)
> at org.apache.kafka.tools.reassign.ReassignPartitionsCommand.getReplicaToLogDir(ReassignPartitionsCommand.java:1689)
> at org.apache.kafka.tools.reassign.ReassignPartitionsCommand.currentPartitionReplicaAssignmentToString(ReassignPartitionsCommand.java:1076)
> at org.apache.kafka.tools.reassign.ReassignPartitionsCommand.executeAssignment(ReassignPartitionsCommand.java:920)
> at org.apache.kafka.tools.reassign.ReassignPartitionsCommand.handleAction(ReassignPartitionsCommand.java:197)
> at org.apache.kafka.tools.reassign.ReassignPartitionsCommand.main(ReassignPartitionsCommand.java:166)
> Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: describeReplicaLogDirs {code}
> This is problematic since kafka-reassign-partitions.sh often is used precisely for moving partitions away from dead brokers.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)