Class DefaultRoutingPolicy (1.16.5)

1.16.5 (latest) 1.16.2 1.15.21 1.14.8 1.13.8 1.12.22 1.11.2 1.10.0 1.9.4 1.8.0 1.7.1 1.6.3 1.5.5 1.4.12

public class DefaultRoutingPolicy implements RoutingPolicy

Inheritance

java.lang.Object > DefaultRoutingPolicy

Implements

RoutingPolicy

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

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