MCPcopy Create free account
hub / github.com/apache/kafka / partition

Method partition

clients/src/main/java/org/apache/kafka/common/Cluster.java:119–121  ·  view source on GitHub ↗

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)

Source from the content-addressed store, hash-verified

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

Callers 9

testSimpleMethod · 0.45
testRetriesMethod · 0.45
ClusterMethod · 0.45
groupDataByTopicMethod · 0.45
MetadataResponseMethod · 0.45

Calls 1

getMethod · 0.45

Tested by 6

testSimpleMethod · 0.36
testRetriesMethod · 0.36