Produced (streams 7.7.7-ce API)

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

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and 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)` Sets the name to be used for an operation.
`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 Detail
  - 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:
    KStream.to(String, Produced)
  - 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:
    KStream.to(String, Produced)
  - 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:
    KStream.to(String, Produced)
  - 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:
    KStream.to(String, Produced)
  - 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:
    KStream.to(String, Produced)
  - 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)
```
    Sets the name to be used for an operation.
    Parameters:
    name - the name to use.
    Returns:
    an instance of NamedOperation

Class Produced<K,V>

Method Summary

Methods inherited from class java.lang.Object

Method Detail

with

with

as

keySerde

valueSerde

streamPartitioner

withStreamPartitioner

withValueSerde

withKeySerde

equals

hashCode

withName