com.avast.sst.fs2kafka
package com.avast.sst.fs2kafka
Type members
Classlikes
@nowarn("msg=dead code")
final case class ConsumerConfig(bootstrapServers: List[String], groupId: String, groupInstanceId: Option[String], clientId: Option[String], clientRack: Option[String], autoOffsetReset: AutoOffsetReset, enableAutoCommit: Boolean, autoCommitInterval: FiniteDuration, allowAutoCreateTopics: Boolean, closeTimeout: FiniteDuration, commitRecovery: CommitRecovery, commitTimeout: FiniteDuration, defaultApiTimeout: FiniteDuration, heartbeatInterval: FiniteDuration, isolationLevel: IsolationLevel, maxPrefetchBatches: Int, pollInterval: FiniteDuration, pollTimeout: FiniteDuration, maxPollInterval: FiniteDuration, maxPollRecords: Int, requestTimeout: FiniteDuration, sessionTimeout: FiniteDuration, properties: Map[String, String])
- Companion:
- object
final case class ProducerConfig(bootstrapServers: List[String], clientId: Option[String], acks: Acks, batchSize: Int, closeTimeout: FiniteDuration, deliveryTimeout: FiniteDuration, requestTimeout: FiniteDuration, linger: FiniteDuration, enableIdempotence: Boolean, maxInFlightRequestsPerConnection: Int, parallelism: Int, retries: Int, properties: Map[String, String])
- Companion:
- object