Class StreamSourceNode<K,​V>

    • Constructor Detail

      • StreamSourceNode

        public StreamSourceNode​(java.lang.String nodeName,
                                java.util.Collection<java.lang.String> topicNames,
                                ConsumedInternal<K,​V> consumedInternal)
      • StreamSourceNode

        public StreamSourceNode​(java.lang.String nodeName,
                                java.util.regex.Pattern topicPattern,
                                ConsumedInternal<K,​V> consumedInternal)
    • Method Detail

      • topicNames

        public java.util.Collection<java.lang.String> topicNames()
      • topicPattern

        public java.util.regex.Pattern topicPattern()
      • keySerde

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

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