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)
