Class ConfigurableWordCountTopology

    • Constructor Detail

      • ConfigurableWordCountTopology

        public ConfigurableWordCountTopology()
    • Method Detail

      • 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.
      • get

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