Chong Wang created KAFKA-6545: --------------------------------- Summary: AdminUtils.fetchTopicMetadataFromZk is not available in 1.0.0 Key: KAFKA-6545 URL: https://issues.apache.org/jira/browse/KAFKA-6545 Project: Kafka Issue Type: Bug Components: admin Affects Versions: 1.0.0 Reporter: Chong Wang
Not sure why this function is deleted, our code was relying on it. final MetadataResponse.TopicMetadata topicMetadata = AdminUtils.fetchTopicMetadataFromZk(topicName, zkUtils); final Topic topic = new Topic(); topic.setPartitions(topicMetadata.partitionMetadata().size()); final int replicas = topicMetadata.partitionMetadata().stream().mapToInt(e -> e.replicas().size()).sum(); topic.setReplications(replicas); -- This message was sent by Atlassian JIRA (v7.6.3#76005)