Package com.bakdata.kafka

Interface ConfiguredApp<E>

Type Parameters:
E - type of executable app after configuring RuntimeConfiguration
All Superinterfaces:
AutoCloseable
All Known Implementing Classes:
ConfiguredProducerApp, ConfiguredStreamsApp
public interface ConfiguredApp<E> extends AutoCloseable
An application with a corresponding configuration

  • Method Details

    • withRuntimeConfiguration

      E withRuntimeConfiguration(RuntimeConfiguration runtimeConfiguration)
      Create an executable app using the provided RuntimeConfiguration.
      Parameters:
      runtimeConfiguration - configuration to run app with
      Returns:
      executable streams app

    • close

      void close()
      Specified by:
      close in interface AutoCloseable