Type Members

1.  final case class Backup(kafkaGroupId: String, timeConfiguration: TimeConfiguration, commitTimeoutBufferWindow: FiniteDuration, compression: Option[Compression]) extends Product with Serializable
   kafkaGroupId

   The group-id that the Kafka consumer will use

   timeConfiguration

   Determines how the backed up objects/files are segregated depending on a time configuration

   commitTimeoutBufferWindow

   A buffer that is added ontop of the timeConfiguration when setting the Kafka Consumer commit timeout.

   compression

   Which compression to use for the backed up data

2.  final case class ChronoUnitSlice(chronoUnit: ChronoUnit) extends TimeConfiguration with Product with Serializable

   Backs up objects/files by collecting received Kafka messages into a single time slice based on a java.time.temporal.ChronoUnit.

   Backs up objects/files by collecting received Kafka messages into a single time slice based on a java.time.temporal.ChronoUnit. When suspending/resuming the backup client, this option will reuse existing objects/files if they fall into the currently configured chronoUnit.

   chronoUnit

   Timestamps for kafka messages that are contained within the configured java.time.temporal.ChronoUnit will be placed into the same object/file.

3.  final case class Compression(type: CompressionType, level: Option[Int]) extends Product with Serializable
4.  final case class PeriodFromFirst(duration: FiniteDuration) extends TimeConfiguration with Product with Serializable

   Backs up objects/files depending on the timestamp fo the first received Kafka message.

   Backs up objects/files depending on the timestamp fo the first received Kafka message. Suspending/resuming the backup client will always create a new object/file

   duration

   The maximum span of time for each object/file, when this duration is exceeded a new file is created

5.  sealed trait TimeConfiguration extends AnyRef