Class SourceNode<K,​V>

    • Constructor Detail

      • SourceNode

        public SourceNode​(java.lang.String name,
                          TimestampExtractor timestampExtractor,
                          org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
                          org.apache.kafka.common.serialization.Deserializer<V> valDeserializer)
      • SourceNode

        public SourceNode​(java.lang.String name,
                          org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
                          org.apache.kafka.common.serialization.Deserializer<V> valDeserializer)