Class OptimizedTopologyProvider

    • Constructor Detail

      • OptimizedTopologyProvider

        public OptimizedTopologyProvider()
    • Method Detail

      • configure

        public void configure​(Conf configuration)
        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()
        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.
      • getStreamBuilder

        protected abstract org.apache.kafka.streams.StreamsBuilder getStreamBuilder()
        Returns the StreamsBuilder which is used to build the Topology instance.
        Returns:
        a StreamsBuilder instance.