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