Class RandomPartitionKeyGenerator


  • public class RandomPartitionKeyGenerator
    extends java.lang.Object
    This class can be used to generate random partition keys when sending messages to Apache Kafka.
    • Constructor Detail

      • RandomPartitionKeyGenerator

        public RandomPartitionKeyGenerator()
      • RandomPartitionKeyGenerator

        public RandomPartitionKeyGenerator​(int maximum)
    • Method Detail

      • getPartitionKey

        public int getPartitionKey()