com.lightbend.lagom.javadsl.api.broker.kafka

Interface PartitionKeyStrategy<Message>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface PartitionKeyStrategy<Message>

Defines an algorithm for producing a key from a Message.

Method Summary

Modifier and Type	Method and Description
String	computePartitionKey(Message message) Computes a key from a message.

Method Detail

computePartitionKey

String computePartitionKey(Message message)

Computes a key from a message. The key is used to decide on what topic's partition a message should be published to.

Parameters:

message - The message to publish into a Kafka topic.

Returns:

A key used to decide on what topic's partition the passed message is published to.