org.apache.kafka.streams.kstream

Class Serialized<K,V>

java.lang.Object

org.apache.kafka.streams.kstream.Serialized<K,V>

Type Parameters:

K - the key type

V - the value type

Deprecated.

since 2.1. Use Grouped instead

@Deprecated
public class Serialized<K,V>
extends java.lang.Object

The class that is used to capture the key and value Serdes used when performing KStream.groupBy(KeyValueMapper, Serialized) and KStream.groupByKey(Serialized) operations.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.kafka.common.serialization.Serde<K>	keySerde Deprecated.
protected org.apache.kafka.common.serialization.Serde<V>	valueSerde Deprecated.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Serialized(Serialized<K,V> serialized) Deprecated.

Method Summary

Modifier and Type	Method and Description
static <K,V> Serialized<K,V>	with(org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde) Deprecated. Construct a Serialized instance with the provided key and value Serdes.
Serialized<K,V>	withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde) Deprecated. Construct a Serialized instance with the provided key Serde.
Serialized<K,V>	withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde) Deprecated. Construct a Serialized instance with the provided value Serde.

Methods inherited from class java.lang.Object

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

Field Detail

keySerde

protected final org.apache.kafka.common.serialization.Serde<K> keySerde

Deprecated.

valueSerde

protected final org.apache.kafka.common.serialization.Serde<V> valueSerde

Deprecated.

Constructor Detail

Serialized

protected Serialized(Serialized<K,V> serialized)

Deprecated.

Method Detail

with

public static <K,V> Serialized<K,V> with(org.apache.kafka.common.serialization.Serde<K> keySerde,
                                         org.apache.kafka.common.serialization.Serde<V> valueSerde)

Deprecated.

Construct a Serialized instance with the provided key and value Serdes. If the Serde params are null the default serdes defined in the configs will be used.

Type Parameters:

K - the key type

V - the value type

Parameters:

keySerde - keySerde that will be used to materialize a stream if not specified the default serdes defined in the configs will be used

valueSerde - valueSerde that will be used to materialize a stream if not specified the default serdes defined in the configs will be used

Returns:

a new instance of Serialized configured with the provided serdes

withKeySerde

public Serialized<K,V> withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)

Deprecated.

Construct a Serialized instance with the provided key Serde. If the Serde params are null the default serdes defined in the configs will be used.

Parameters:

keySerde - keySerde that will be used to materialize a stream if not specified the default serdes defined in the configs will be used

Returns:

a new instance of Serialized configured with the provided key serde

withValueSerde

public Serialized<K,V> withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)

Deprecated.

Construct a Serialized instance with the provided value Serde. If the Serde params are null the default serdes defined in the configs will be used.

Parameters:

valueSerde - valueSerde that will be used to materialize a stream if not specified the default serdes defined in the configs will be used

Returns:

a new instance of Serialized configured with the provided key serde