Class DefaultRoutingPolicy (1.7.1) 

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(ByteString messageKey)

public Partition route(ByteString messageKey)
Parameter
Name Description
messageKey ByteString
Returns
Type Description
Partition
Exceptions
Type Description
ApiException

routeWithoutKey()

public Partition routeWithoutKey()
Returns
Type Description
Partition
Exceptions
Type Description
ApiException