org.joyqueue.client.internal.producer.helper

类 ProducerHelper

java.lang.Object

org.joyqueue.client.internal.producer.helper.ProducerHelper

public class ProducerHelper
extends Object

ProducerHelper author: gaohaoxiang date: 2018/12/26

构造器概要

构造器

构造器和说明
ProducerHelper()

方法概要

限定符和类型	方法和说明
static void	clearPartition(ProduceMessage message)
static void	clearPartitions(List<ProduceMessage> messages)
static PartitionMetadata	dispatchPartitions(List<ProduceMessage> messages, TopicMetadata topicMetadata, List<PartitionMetadata> partitions, PartitionSelector partitionSelector)
static List<PartitionMetadata>	filterBlackList(List<PartitionMetadata> partitions, List<PartitionMetadata> blackPartitionList)
static void	setPartitions(List<ProduceMessage> messages, short partition)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

ProducerHelper

public ProducerHelper()

方法详细资料

setPartitions

public static void setPartitions(List<ProduceMessage> messages,
                                 short partition)

clearPartitions

public static void clearPartitions(List<ProduceMessage> messages)

clearPartition

public static void clearPartition(ProduceMessage message)

dispatchPartitions

public static PartitionMetadata dispatchPartitions(List<ProduceMessage> messages,
                                                   TopicMetadata topicMetadata,
                                                   List<PartitionMetadata> partitions,
                                                   PartitionSelector partitionSelector)

filterBlackList

public static List<PartitionMetadata> filterBlackList(List<PartitionMetadata> partitions,
                                                      List<PartitionMetadata> blackPartitionList)