Class DefaultRoutingPolicy (1.13.6)

public class DefaultRoutingPolicy implements RoutingPolicy

Inheritance

java.lang.Object > DefaultRoutingPolicy

Implements

RoutingPolicy

Constructors

DefaultRoutingPolicy(long numPartitions)

public DefaultRoutingPolicy(long numPartitions)
Parameter
Name Description
numPartitions long

Methods

route(PubSubMessage message)

public Partition route(PubSubMessage message)
Parameter
Name Description
message PubSubMessage
Returns
Type Description
Partition