Class AbstractStream<K,​V>

    • Field Detail

      • name

        protected final java.lang.String name
      • keySerde

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

        protected final org.apache.kafka.common.serialization.Serde<V> valSerde
      • sourceNodes

        protected final java.util.Set<java.lang.String> sourceNodes
    • Constructor Detail

    • Method Detail

      • keySerde

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

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