PartitionNode |
MessageProducerInner.dispatchPartitions(List<ProduceMessage> messages,
TopicMetadata topicMetadata,
List<BrokerNode> brokerNodes) |
protected PartitionNode |
AbstractPartitionSelector.hashPartition(ProduceMessage message,
TopicMetadata topicMetadata,
List<BrokerNode> brokerNodes) |
protected PartitionNode |
AdaptivePartitionSelector.nextPartition(ProduceMessage message,
TopicMetadata topicMetadata,
List<BrokerNode> brokerNodes) |
protected abstract PartitionNode |
AbstractPartitionSelector.nextPartition(ProduceMessage message,
TopicMetadata topicMetadata,
List<BrokerNode> brokerNodes) |
protected PartitionNode |
WeightedPartitionSelector.nextPartition(ProduceMessage message,
TopicMetadata topicMetadata,
List<BrokerNode> brokerNodes) |
protected PartitionNode |
AbstractPartitionSelector.randomSelectPartitionNode(TopicMetadata topicMetadata,
BrokerNode brokerNode) |
PartitionNode |
AbstractPartitionSelector.select(ProduceMessage message,
TopicMetadata topicMetadata,
List<BrokerNode> brokerNodes) |
protected PartitionNode |
AbstractPartitionSelector.selectPartition(ProduceMessage message,
TopicMetadata topicMetadata,
List<BrokerNode> brokerNodes) |