Class DefaultRoutingPolicy (1.10.0)

Version 1.10.0

• 1.14.7 (latest)
• 1.14.4
• 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(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