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

Class KafkaProperties

Object

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

public final class KafkaProperties
extends Object

Provides a set of Kafka specific properties that can be used when creating a topic descriptor.

Method Summary

Modifier and Type	Method and Description
static <Message> Descriptor.Properties.Property<Message,PartitionKeyStrategy<Message>>	partitionKeyStrategy() A PartitionKeyStrategy produces a key for each message published to a Kafka topic.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

partitionKeyStrategy

public static <Message> Descriptor.Properties.Property<Message,PartitionKeyStrategy<Message>> partitionKeyStrategy()

A PartitionKeyStrategy produces a key for each message published to a Kafka topic. The key is used to determine on which topic's partition a message is published. It is guaranteed that messages with the same key will arrive to the same partition, in the order they are published.