@ SuppressWarnings ( "unchecked" ) public static < Message > Descriptor . Properties . Property < Message , PartitionKeyStrategy < Message > > partitionKeyStrategy ( ) { return PARTITION_KEY_STRATEGY ; }
A PartitionKeyStrategy produces a key for each message published to a Kafka topic .