Type Members

1.  trait App[T <: KafkaConsumerInterface] extends LazyLogging
2.  trait BackupApp extends Config with kafka.Config with PekkoSettings
3.  trait BackupClientInterface[T <: KafkaConsumerInterface] extends LazyLogging

   An interface for a template on how to backup a Kafka Stream into some data storage

   An interface for a template on how to backup a Kafka Stream into some data storage

   T

   The underlying kafkaClientInterface type

4.  trait Config extends AnyRef
5.  class Entry extends CommandApp
6.  class KafkaConsumer extends KafkaConsumerInterface with LazyLogging

   A Kafka Client that uses Pekko Connectors Kafka Consumer under the hood to create a stream of events from a Kafka cluster.

   A Kafka Client that uses Pekko Connectors Kafka Consumer under the hood to create a stream of events from a Kafka cluster. To configure the Pekko Connectors Kafka Consumer use the standard typesafe configuration i.e. pekko.kafka.consumer (note that the keySerializer and valueSerializer are hardcoded so you cannot override this).

7.  trait KafkaConsumerInterface extends AnyRef
8.  trait S3App extends s3.Config with BackupApp with App[KafkaConsumer]