Class Produced<K,V>

java.lang.Object
org.apache.kafka.streams.kstream.Produced<K,V>
Type Parameters:
K - key type
V - value type
public class Produced<K,V>extends Object
This class is used to provide the optional parameters when producing to new topics using KStream.to(String, Produced).

  • Method Summary

    Modifier and Type
    Method
    Description
    static <K,V> Produced<K,V>
    as(String processorName)
    Create an instance of Produced with provided processor name.
    boolean
    equals(Object o)
     
    int
    hashCode()
     
    static <K,V> Produced<K,V>
    keySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
    Create a Produced instance with provided keySerde.
    static <K,V> Produced<K,V>
    streamPartitioner(StreamPartitioner<? super K, ? super V> partitioner)
    Create a Produced instance with provided partitioner.
    static <K,V> Produced<K,V>
    valueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
    Create a Produced instance with provided valueSerde.
    static <K,V> Produced<K,V>
    with(org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
    Create a Produced instance with provided keySerde and valueSerde.
    static <K,V> Produced<K,V>
    with(org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde, StreamPartitioner<? super K, ? super V> partitioner)
    Create a Produced instance with provided keySerde, valueSerde, and partitioner.
    Produced<K,V>
    withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
    Produce records using the provided keySerde.
    Produced<K,V>
    withName(String name)
     
    Produced<K,V>
    withStreamPartitioner(StreamPartitioner<? super K, ? super V> partitioner)
    Produce records using the provided partitioner.
    Produced<K,V>
    withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
    Produce records using the provided valueSerde.

    Methods inherited from class java.lang.Object

    getClass, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • with

      public static <K,V> Produced<K,V> with(org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
      Create a Produced instance with provided keySerde and valueSerde.
      Type Parameters:
      K - key type
      V - value type
      Parameters:
      keySerde - Serde to use for serializing the key
      valueSerde - Serde to use for serializing the value
      Returns:
      A new Produced instance configured with keySerde and valueSerde
      See Also:

    • with

      public static <K,V> Produced<K,V> with(org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde, StreamPartitioner<? super K, ? super V> partitioner)
      Create a Produced instance with provided keySerde, valueSerde, and partitioner.
      Type Parameters:
      K - key type
      V - value type
      Parameters:
      keySerde - Serde to use for serializing the key
      valueSerde - Serde to use for serializing the value
      partitioner - the function used to determine how records are distributed among partitions of the topic, if not specified and keySerde provides a WindowedSerializer for the key WindowedStreamPartitioner will be used—otherwise DefaultStreamPartitioner will be used
      Returns:
      A new Produced instance configured with keySerde, valueSerde, and partitioner
      See Also:

    • as

      public static <K,V> Produced<K,V> as(String processorName)
      Create an instance of Produced with provided processor name.
      Type Parameters:
      K - key type
      V - value type
      Parameters:
      processorName - the processor name to be used. If null a default processor name will be generated
      Returns:
      a new instance of Produced

    • keySerde

      public static <K,V> Produced<K,V> keySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
      Create a Produced instance with provided keySerde.
      Type Parameters:
      K - key type
      V - value type
      Parameters:
      keySerde - Serde to use for serializing the key
      Returns:
      A new Produced instance configured with keySerde
      See Also:

    • valueSerde

      public static <K,V> Produced<K,V> valueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
      Create a Produced instance with provided valueSerde.
      Type Parameters:
      K - key type
      V - value type
      Parameters:
      valueSerde - Serde to use for serializing the key
      Returns:
      A new Produced instance configured with valueSerde
      See Also:

    • streamPartitioner

      public static <K,V> Produced<K,V> streamPartitioner(StreamPartitioner<? super K, ? super V> partitioner)
      Create a Produced instance with provided partitioner.
      Type Parameters:
      K - key type
      V - value type
      Parameters:
      partitioner - the function used to determine how records are distributed among partitions of the topic, if not specified and the key serde provides a WindowedSerializer for the key WindowedStreamPartitioner will be used—otherwise DefaultStreamPartitioner will be used
      Returns:
      A new Produced instance configured with partitioner
      See Also:

    • withStreamPartitioner

      public Produced<K,V> withStreamPartitioner(StreamPartitioner<? super K, ? super V> partitioner)
      Produce records using the provided partitioner.
      Parameters:
      partitioner - the function used to determine how records are distributed among partitions of the topic, if not specified and the key serde provides a WindowedSerializer for the key WindowedStreamPartitioner will be used—otherwise DefaultStreamPartitioner will be used
      Returns:
      this

    • withValueSerde

      public Produced<K,V> withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
      Produce records using the provided valueSerde.
      Parameters:
      valueSerde - Serde to use for serializing the value
      Returns:
      this

    • withKeySerde

      public Produced<K,V> withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
      Produce records using the provided keySerde.
      Parameters:
      keySerde - Serde to use for serializing the key
      Returns:
      this

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • withName

      public Produced<K,V> withName(String name)