Class ConsumedInternal<K,​V>


  • public class ConsumedInternal<K,​V>
    extends Consumed<K,​V>
    • Constructor Detail

      • ConsumedInternal

        public ConsumedInternal​(Consumed<K,​V> consumed)
      • ConsumedInternal

        public ConsumedInternal​(org.apache.kafka.common.serialization.Serde<K> keySerde,
                                org.apache.kafka.common.serialization.Serde<V> valSerde,
                                TimestampExtractor timestampExtractor,
                                Topology.AutoOffsetReset offsetReset)
      • ConsumedInternal

        public ConsumedInternal()
    • Method Detail

      • keySerde

        public org.apache.kafka.common.serialization.Serde<K> keySerde()
      • keyDeserializer

        public org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer()
      • valueSerde

        public org.apache.kafka.common.serialization.Serde<V> valueSerde()
      • valueDeserializer

        public org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer()