public final class KafkaProperties extends Object
|Modifier and Type||Method and Description|
A PartitionKeyStrategy produces a key for each message published to a Kafka topic.
public static <Message> Descriptor.Properties.Property<Message,PartitionKeyStrategy<Message>> partitionKeyStrategy()
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.