Type Members

1.  final case class ConsumerConfig(bootstrapServers: List[String], groupId: String, groupInstanceId: Option[String] = None, clientId: Option[String] = None, clientRack: Option[String] = None, autoOffsetReset: AutoOffsetReset = AutoOffsetReset.None, enableAutoCommit: Boolean = false, autoCommitInterval: FiniteDuration = defaultMillis(ApacheConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG), allowAutoCreateTopics: Boolean = default(ApacheConsumerConfig.ALLOW_AUTO_CREATE_TOPICS_CONFIG), closeTimeout: FiniteDuration = FiniteDuration(20, SECONDS), commitRecovery: CommitRecovery = CommitRecovery.Default, commitTimeout: FiniteDuration = FiniteDuration(15, SECONDS), defaultApiTimeout: FiniteDuration = defaultMillis(ApacheConsumerConfig.DEFAULT_API_TIMEOUT_MS_CONFIG), heartbeatInterval: FiniteDuration = defaultMillis(ApacheConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG), isolationLevel: IsolationLevel = defaultIsolationLevel, maxPrefetchBatches: Int = 2, pollInterval: FiniteDuration = FiniteDuration(50, MILLISECONDS), pollTimeout: FiniteDuration = FiniteDuration(50, MILLISECONDS), maxPollInterval: FiniteDuration = defaultMillis(ApacheConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG), maxPollRecords: Int = default(ApacheConsumerConfig.MAX_POLL_RECORDS_CONFIG), requestTimeout: FiniteDuration = defaultMillis(ApacheConsumerConfig.REQUEST_TIMEOUT_MS_CONFIG), sessionTimeout: FiniteDuration = defaultMillis(ApacheConsumerConfig.SESSION_TIMEOUT_MS_CONFIG), properties: Map[String, String] = Map.empty) extends Product with Serializable

   Annotations

   @nowarn()

2.  final case class ProducerConfig(bootstrapServers: List[String], clientId: Option[String] = None, acks: Acks = defaultAcks, batchSize: Int = default[Int](ApacheProducerConfig.BATCH_SIZE_CONFIG), closeTimeout: FiniteDuration = FiniteDuration(60, SECONDS), deliveryTimeout: FiniteDuration = defaultMillis(ApacheProducerConfig.DELIVERY_TIMEOUT_MS_CONFIG), requestTimeout: FiniteDuration = defaultMillis(ApacheProducerConfig.REQUEST_TIMEOUT_MS_CONFIG), linger: FiniteDuration = defaultMillisLong(ApacheProducerConfig.LINGER_MS_CONFIG), enableIdempotence: Boolean = default[Boolean](ApacheProducerConfig.ENABLE_IDEMPOTENCE_CONFIG), maxInFlightRequestsPerConnection: Int = default[Int](ApacheProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION), parallelism: Int = 100, retries: Int = 0, properties: Map[String, String] = Map.empty) extends Product with Serializable