package configs
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- final case class S3(dataBucket: String, dataBucketPrefix: Option[String], errorRestartSettings: RestartSettings) extends Product with Serializable
S3 specific configuration used when storing Kafka ConsumerRecords to a S3 bucket
S3 specific configuration used when storing Kafka ConsumerRecords to a S3 bucket
- dataBucket
The bucket where a Kafka Consumer directly streams data into as storage
- dataBucketPrefix
Prefix for the data bucket (if any)
- errorRestartSettings
Restart settings that are used whenever an pekko-stream encounters an error
Value Members
- object S3 extends Serializable