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

Reply via email to