MINOR: Fix unrelated types comparison in MetadataRequestTest (apache#…

…8195) The type of `leaderId` was changed to `Optional` in a recent change. Reviewers: Ismael Juma <[email protected]>
hy-good · Feb 29, 2020 · 0df03a6 · 0df03a6
1 parent e0551ac
commit 0df03a6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/test/scala/unit/kafka/server/MetadataRequestTest.scala b/core/src/test/scala/unit/kafka/server/MetadataRequestTest.scala
@@ -274,7 +274,7 @@ class MetadataRequestTest extends BaseRequestTest {
       val serverId = server.dataPlaneRequestProcessor.brokerId
       val leaderId = partitionMetadata.leaderId
       val replicaIds = partitionMetadata.replicaIds.asScala
-      serverId != leaderId && replicaIds.contains(serverId)
+      leaderId.isPresent && leaderId.get() != serverId && replicaIds.contains(serverId)
     }.get
     downNode.shutdown()