Interface ProducerIterator<M extends Message>

    • Method Detail

      • remove

        default void remove()
        The remove method is not needed.
        Specified by:
        remove in interface Iterator<M extends Message>
      • 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