Class ContextAwareKafkaStreamsFactorySupplier.DelegateKafkaStreamsFactory

    • Method Detail

      • make

        public org.apache.kafka.streams.KafkaStreams make​(org.apache.kafka.streams.Topology topology,
                                                          Conf streamsConfig)
        Creates a new KafkaStreams instance for the given topology and config.
        Specified by:
        make in interface KafkaStreamsFactory
        Parameters:
        topology - the Topology instance.
        streamsConfig - the streams configuration.
        Returns:
        the KafkaStreams instance.