public final class KafkaProperties extends Object
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.
|
public static <Message> Descriptor.Properties.Property<Message,PartitionKeyStrategy<Message>> partitionKeyStrategy()