Class SourceNode<K,​V>

    • Constructor Summary

      Constructors 
      Constructor Description
      SourceNode​(java.lang.String name, java.util.List<java.lang.String> topics, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valDeserializer)  
      SourceNode​(java.lang.String name, java.util.List<java.lang.String> topics, TimestampExtractor timestampExtractor, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valDeserializer)  
    • Constructor Detail

      • SourceNode

        public SourceNode​(java.lang.String name,
                          java.util.List<java.lang.String> topics,
                          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,
                          java.util.List<java.lang.String> topics,
                          org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
                          org.apache.kafka.common.serialization.Deserializer<V> valDeserializer)
    • Method Detail

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class ProcessorNode<K,​V>
        Returns:
        a string representation of this node, useful for debugging.
      • toString

        public java.lang.String toString​(java.lang.String indent)
        Overrides:
        toString in class ProcessorNode<K,​V>
        Returns:
        a string representation of this node starting with the given indent, useful for debugging.