public class ConsumedInternal<K,V> extends Consumed<K,V>
keySerde, resetPolicy, timestampExtractor, valueSerde
Constructor and Description |
---|
ConsumedInternal() |
ConsumedInternal(Consumed<K,V> consumed) |
ConsumedInternal(org.apache.kafka.common.serialization.Serde<K> keySerde,
org.apache.kafka.common.serialization.Serde<V> valSerde,
TimestampExtractor timestampExtractor,
Topology.AutoOffsetReset offsetReset) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Deserializer<K> |
keyDeserializer() |
org.apache.kafka.common.serialization.Serde<K> |
keySerde() |
Topology.AutoOffsetReset |
offsetResetPolicy() |
TimestampExtractor |
timestampExtractor() |
org.apache.kafka.common.serialization.Deserializer<V> |
valueDeserializer() |
org.apache.kafka.common.serialization.Serde<V> |
valueSerde() |
equals, hashCode, with, with, with, with, withKeySerde, withOffsetResetPolicy, withTimestampExtractor, withValueSerde
public ConsumedInternal(org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valSerde, TimestampExtractor timestampExtractor, Topology.AutoOffsetReset offsetReset)
public ConsumedInternal()
public org.apache.kafka.common.serialization.Serde<K> keySerde()
public org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer()
public org.apache.kafka.common.serialization.Serde<V> valueSerde()
public org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer()
public TimestampExtractor timestampExtractor()
public Topology.AutoOffsetReset offsetResetPolicy()