Interface StreamsPartitioner

    • 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, int numPartitions)
      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,
                      int numPartitions)
        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
        numPartitions - Number of partitions the topic has
      • close

        void close()
        This is called when partitioner is closed.