Class ComplexWordCountTopology

    • Constructor Detail

      • ComplexWordCountTopology

        public ComplexWordCountTopology()
    • Method Detail

      • setStopWordsService

        public void setStopWordsService​(StopWordsService stopWords)
      • configure

        public void configure​(Conf configuration)
        Description copied from interface: Configurable
        Configures this instance with the specified Conf.
        Specified by:
        configure in interface Configurable
        Parameters:
        configuration - the Conf instance used to configure this instance.
      • topology

        public org.apache.kafka.streams.Topology topology()
        Description copied from interface: TopologyProvider
        Supplies a new Kafka Streams Topology instance.
        Specified by:
        topology in interface Provider<org.apache.kafka.streams.Topology>
        Specified by:
        topology in interface TopologyProvider
        Returns:
        the Topology instance.