Interface ProducerIterator<M extends Message>

    • Method Detail

      • getPartition

        int getPartition​(M message,
                         int partitions)
        Returns a partition associated with the Message. The value returned must be between 0 and lower than partitions.
        Parameters:
        message - the message to shard
        partitions - the number of partitions