mirror of https://github.com/apache/kafka.git
MINOR: Fix unrelated types comparison in MetadataRequestTest (#8195)
The type of `leaderId` was changed to `Optional` in a recent change. Reviewers: Ismael Juma <ismael@juma.me.uk>
This commit is contained in:
parent
e0551acce4
commit
0df03a681c
|
|
@ -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()
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue