Class DefaultRoutingPolicy (1.12.3)

public class DefaultRoutingPolicy implements RoutingPolicy

Inheritance

java.lang.Object > DefaultRoutingPolicy

Implements

RoutingPolicy

Constructors

DefaultRoutingPolicy(long numPartitions)

public DefaultRoutingPolicy(long numPartitions)
Parameter
NameDescription
numPartitionslong

Methods

route(PubSubMessage message)

public Partition route(PubSubMessage message)
Parameter
NameDescription
messagePubSubMessage
Returns
TypeDescription
Partition