Package com.bakdata.kafka

Interface App<T,C>

Type Parameters:
T - type of topic config
C - type of clean up config
All Superinterfaces:
AutoCloseable
All Known Subinterfaces:
LargeMessageProducerApp, LargeMessageStreamsApp, ProducerApp, StreamsApp
public interface App<T,C> extends AutoCloseable
Kafka application that defines necessary configurations

  • Method Details

    • setupCleanUp

      C setupCleanUp(AppConfiguration<T> configuration)
      Configure clean up behavior
      Parameters:
      configuration - provides all runtime application configurations
      Returns:
      clean up configuration

    • close

      default void close()
      Specified by:
      close in interface AutoCloseable

    • createKafkaProperties

      default Map<String,Object> createKafkaProperties()
      This method should give a default configuration to run your application with.
      Returns:
      Returns a default Kafka configuration. Empty by default

    • setup

      default void setup(AppConfiguration<T> configuration)
      Setup Kafka resources, such as topics, before running this app
      Parameters:
      configuration - provides all runtime application configurations

    • defaultSerializationConfig

      SerializationConfig defaultSerializationConfig()
      Configure default serialization behavior
      Returns:
      SerializationConfig