uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/KafkaBrokerTopicObserver.java [132:138]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
          try {
            scala.collection.Map<Object, Seq<Object>> partitionsMap =
                partitionAssignmentForTopics.get(topic).get();
            TopicPartition tp = new TopicPartition(topic, partitionsMap.size());
            _topicPartitionInfoMap.put(topic, tp);
          } catch (Exception e) {
            LOGGER.warn("Failed to get topicPartition info for {} from kafka zk: {}", topic, e);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uReplicator-Common/src/main/java/com/uber/stream/kafka/mirrormaker/common/core/KafkaBrokerTopicObserver.java [216:222]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        try {
          scala.collection.Map<Object, Seq<Object>> partitionsMap =
              partitionAssignmentForTopics.get(topic).get();
          TopicPartition tp = new TopicPartition(topic, partitionsMap.size());
          _topicPartitionInfoMap.put(topic, tp);
        } catch (Exception e) {
          LOGGER.warn("Failed to get topicPartition info for {} from kafka zk: {}", topic, e);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -