Package org.apache.kafka.streams.kstream.internals

Class ConsumedInternal<K,V>

java.lang.Object

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

org.apache.kafka.streams.kstream.internals.ConsumedInternal<K,V>

public class ConsumedInternal<K,V>
extends Consumed<K,V>

Field Summary

Fields inherited from class org.apache.kafka.streams.kstream.Consumed

keySerde, processorName, resetPolicy, timestampExtractor, valueSerde

Constructor Summary

Constructors

Constructor	Description
ConsumedInternal()
ConsumedInternal(Serde<K> keySerde, Serde<V> valSerde, TimestampExtractor timestampExtractor, Topology.AutoOffsetReset offsetReset)
ConsumedInternal(Consumed<K,V> consumed)

Method Summary

Modifier and Type	Method	Description
Deserializer<K>	keyDeserializer()
Serde<K>	keySerde()
String	name()
Topology.AutoOffsetReset	offsetResetPolicy()
TimestampExtractor	timestampExtractor()
Deserializer<V>	valueDeserializer()
Serde<V>	valueSerde()

Methods inherited from class org.apache.kafka.streams.kstream.Consumed

as, equals, hashCode, with, with, with, with, withKeySerde, withName, withOffsetResetPolicy, withTimestampExtractor, withValueSerde

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumedInternal

public ConsumedInternal(Consumed<K,V> consumed)

ConsumedInternal

public ConsumedInternal(Serde<K> keySerde,
                        Serde<V> valSerde,
                        TimestampExtractor timestampExtractor,
                        Topology.AutoOffsetReset offsetReset)

ConsumedInternal

public ConsumedInternal()

Method Detail

keySerde

public Serde<K> keySerde()

keyDeserializer

public Deserializer<K> keyDeserializer()

valueSerde

public Serde<V> valueSerde()

valueDeserializer

public Deserializer<V> valueDeserializer()

timestampExtractor

public TimestampExtractor timestampExtractor()

offsetResetPolicy

public Topology.AutoOffsetReset offsetResetPolicy()

name

public String name()