Package com.bakdata.kafka

Interface ExecutableApp<R,C,O>

Type Parameters:
R - type returned by createRunner() and createRunner(Object)
C - type returned by createCleanUpRunner()
O - type of options to create runner
All Superinterfaces:
AutoCloseable
All Known Implementing Classes:
ExecutableProducerApp, ExecutableStreamsApp
public interface ExecutableApp<R,C,O> extends AutoCloseable
An application with a corresponding topic and Kafka configuration

  • Method Details

    • close

      void close()
      Specified by:
      close in interface AutoCloseable

    • createRunner

      R createRunner()
      Create Runner in order to run application with default options
      Returns:
      Runner

    • createRunner

      R createRunner(O options)
      Create Runner in order to run application
      Parameters:
      options - options for creating runner
      Returns:
      Runner

    • createCleanUpRunner

      C createCleanUpRunner()
      Create CleanUpRunner in order to clean application
      Returns:
      CleanUpRunner