Package org.apache.kafka.clients.producer

Interface Partitioner

  • All Superinterfaces:
    java.lang.AutoCloseable, java.io.Closeable, Configurable
    public interface Partitioner
extends Configurable, java.io.Closeable
    Partitioner Interface is not supported.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void close()
      This is called when partitioner is closed.
      int partition​(java.lang.String topic, java.lang.Object key, byte[] keyBytes, java.lang.Object value, byte[] valueBytes, Cluster cluster)
      Compute the partition for the given record.

    • Method Detail

      • partition

        int partition​(java.lang.String topic,
              java.lang.Object key,
              byte[] keyBytes,
              java.lang.Object value,
              byte[] valueBytes,
              Cluster cluster)
        Compute the partition for the given record.
        Parameters:
        topic - The topic name
        key - The key to partition on (or null if no key)
        keyBytes - The serialized key to partition on( or null if no key)
        value - The value to partition on or null
        valueBytes - The serialized value to partition on or null
        cluster - The current cluster metadata

      • close

        void close()
        This is called when partitioner is closed.
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable