Class DefaultRoutingPolicy (1.10.0)

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

public Partition route(ByteString messageKey)
Parameter
NameDescription
messageKeyByteString
Returns
TypeDescription
Partition
Exceptions
TypeDescription
ApiException

routeWithoutKey()

public Partition routeWithoutKey()
Returns
TypeDescription
Partition
Exceptions
TypeDescription
ApiException