Interface RoutingPolicy (1.11.0)

public interface RoutingPolicy

Methods

route(ByteString messageKey)

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

routeWithoutKey()

public abstract Partition routeWithoutKey()
Returns
TypeDescription
Partition
Exceptions
TypeDescription
CheckedApiException