org.apache.kafka.streams.kstream

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.through(String, Produced) or KStream.to(String, Produced).

Field Summary

Fields

Modifier and Type	Field and Description
protected Serde<K>	keySerde
protected StreamPartitioner<? super K,? super V>	partitioner
protected String	processorName
protected Serde<V>	valueSerde

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Produced(Produced<K,V> produced)

Method Summary

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(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(Serde<V> valueSerde) Create a Produced instance with provided valueSerde.
static <K,V> Produced<K,V>	with(Serde<K> keySerde, Serde<V> valueSerde) Create a Produced instance with provided keySerde and valueSerde.
static <K,V> Produced<K,V>	with(Serde<K> keySerde, Serde<V> valueSerde, StreamPartitioner<? super K,? super V> partitioner) Create a Produced instance with provided keySerde, valueSerde, and partitioner.
Produced<K,V>	withKeySerde(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(Serde<V> valueSerde) Produce records using the provided valueSerde.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Detail

keySerde

protected Serde<K> keySerde

valueSerde

protected Serde<V> valueSerde

partitioner

protected StreamPartitioner<? super K,? super V> partitioner

processorName

protected String processorName

Constructor Detail

Produced

protected Produced(Produced<K,V> produced)

Method Detail

with

public static <K,V> Produced<K,V> with(Serde<K> keySerde,
                                       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.through(String, Produced), KStream.to(String, Produced)

with

public static <K,V> Produced<K,V> with(Serde<K> keySerde,
                                       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 DefaultPartitioner will be used

Returns:

A new Produced instance configured with keySerde, valueSerde, and partitioner

See Also:

KStream.through(String, Produced), 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(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.through(String, Produced), KStream.to(String, Produced)

valueSerde

public static <K,V> Produced<K,V> valueSerde(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.through(String, Produced), 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 DefaultPartitioner will be used

Returns:

A new Produced instance configured with partitioner

See Also:

KStream.through(String, Produced), 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 DefaultPartitioner wil be used

Returns:

this

withValueSerde

public Produced<K,V> withValueSerde(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(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