You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mi...@apache.org on 2020/04/09 14:25:11 UTC
[kafka] branch trunk updated: KAFKA-9691: Fix NPE by waiting for
reassignment request (#8317)
This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 371ad14 KAFKA-9691: Fix NPE by waiting for reassignment request (#8317)
371ad14 is described below
commit 371ad143a6bb973927c89c0788d048a17ebac91a
Author: Tom Bentley <to...@users.noreply.github.com>
AuthorDate: Thu Apr 9 15:24:44 2020 +0100
KAFKA-9691: Fix NPE by waiting for reassignment request (#8317)
Reviewers: Mickael Maison <mi...@gmail.com>, Stanislav Kozlovski <st...@outlook.com>, Chia-Ping Tsai <ch...@gmail.com>
---
.../test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala b/core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala
index 3f95038e..78a4a6f 100644
--- a/core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala
+++ b/core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala
@@ -665,7 +665,7 @@ class TopicCommandWithAdminClientTest extends KafkaServerTestHarness with Loggin
val targetReplica = brokerIds.diff(replicasOfFirstPartition).head
adminClient.alterPartitionReassignments(Collections.singletonMap(tp,
- Optional.of(new NewPartitionReassignment(Collections.singletonList(targetReplica)))))
+ Optional.of(new NewPartitionReassignment(Collections.singletonList(targetReplica))))).all().get()
// let's wait until the LAIR is propagated
TestUtils.waitUntilTrue(() => {