Packages

package configs

Type Members

  1. final case class GCS(dataBucket: String, compactionBucket: String) extends Product with Serializable

    GCS specific configuration used when storing Kafka ConsumerRecords to a GCS bucket

    GCS specific configuration used when storing Kafka ConsumerRecords to a GCS bucket

    dataBucket

    The bucket where a Kafka Consumer directly streams data into as storage

    compactionBucket

    The bucket where compaction results are stored

Ungrouped