Class DefaultStreamsPartitioner

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()
      This is called when partitioner is closed.
      void configure​(java.util.Map<java.lang.String,​?> configs)
      Configure this class with the given key-value pairs
      int partition​(java.lang.String topic, java.lang.Object key, byte[] keyBytes, java.lang.Object value, byte[] valueBytes, int numPartitions)
      Compute the partition for the given record.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • DefaultStreamsPartitioner

        public DefaultStreamsPartitioner()
    • Method Detail

      • configure

        public void configure​(java.util.Map<java.lang.String,​?> configs)
        Description copied from interface: Configurable
        Configure this class with the given key-value pairs
        Specified by:
        configure in interface Configurable
      • partition

        public int partition​(java.lang.String topic,
                             java.lang.Object key,
                             byte[] keyBytes,
                             java.lang.Object value,
                             byte[] valueBytes,
                             int numPartitions)
        Compute the partition for the given record.
        Specified by:
        partition in interface StreamsPartitioner
        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
        numPartitions - Number of partitions the topic has
      • close

        public void close()
        This is called when partitioner is closed.
        Specified by:
        close in interface StreamsPartitioner