Get the metadata for the specified partition @param topicPartition The topic and partition to fetch info for @return The metadata about the given topic and partition
(TopicPartition topicPartition)
| 117 | * @return The metadata about the given topic and partition |
| 118 | */ |
| 119 | public PartitionInfo partition(TopicPartition topicPartition) { |
| 120 | return partitionsByTopicPartition.get(topicPartition); |
| 121 | } |
| 122 | |
| 123 | /** |
| 124 | * Get the list of partitions for this topic |