Hi, For the following code which works against 0.10 : def isPropagated = server.apis.metadataCache.getPartitionInfo(topic, partition) match { case Some(partitionState) => val leaderAndInSyncReplicas = partitionState.leaderIsrAndControllerEpoch.leaderAndIsr
I got the this error compiling against 2.0 : value leaderIsrAndControllerEpoch is not a member of org.apache.kafka.common.requests.UpdateMetadataRequest.PartitionState [ERROR] val leaderAndInSyncReplicas = partitionState.leaderIsrAndControllerEpoch.leaderAndIsr Please comment on the replacement API. Thanks