Packages

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()
Linear Supertypes
Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ConsumerConfig
  2. Serializable
  3. Product
  4. Equals
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new 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)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. val allowAutoCreateTopics: Boolean
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. val autoCommitInterval: FiniteDuration
  7. val autoOffsetReset: AutoOffsetReset
  8. val bootstrapServers: List[String]
  9. val clientId: Option[String]
  10. val clientRack: Option[String]
  11. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
  12. val closeTimeout: FiniteDuration
  13. val commitRecovery: CommitRecovery
  14. val commitTimeout: FiniteDuration
  15. val defaultApiTimeout: FiniteDuration
  16. val enableAutoCommit: Boolean
  17. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  19. val groupId: String
  20. val groupInstanceId: Option[String]
  21. val heartbeatInterval: FiniteDuration
  22. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  23. val isolationLevel: IsolationLevel
  24. val maxPollInterval: FiniteDuration
  25. val maxPollRecords: Int
  26. val maxPrefetchBatches: Int
  27. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  28. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  29. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  30. val pollInterval: FiniteDuration
  31. val pollTimeout: FiniteDuration
  32. def productElementNames: Iterator[String]
    Definition Classes
    Product
  33. val properties: Map[String, String]
  34. val requestTimeout: FiniteDuration
  35. val sessionTimeout: FiniteDuration
  36. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  37. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  38. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  39. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped