class ConsumerSettings[K, V] extends AnyRef

Settings for consumers. See akka.kafka.consumer section in reference.conf. Note that the companion object provides apply and create functions for convenient construction of the settings, together with the with methods.

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ConsumerSettings
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ConsumerSettings(properties: Map[String, String], keyDeserializerOpt: Option[Deserializer[K]], valueDeserializerOpt: Option[Deserializer[V]], pollInterval: FiniteDuration, pollTimeout: FiniteDuration, stopTimeout: FiniteDuration, closeTimeout: FiniteDuration, commitTimeout: FiniteDuration, wakeupTimeout: FiniteDuration, maxWakeups: Int, commitRefreshInterval: Duration, dispatcher: String, commitTimeWarning: FiniteDuration = 1.second, wakeupDebug: Boolean = true, waitClosePartition: FiniteDuration)

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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  6. val closeTimeout: FiniteDuration
  7. val commitRefreshInterval: Duration
  8. val commitTimeWarning: FiniteDuration
  9. val commitTimeout: FiniteDuration
  10. def createKafkaConsumer(): Consumer[K, V]

    Create a KafkaConsumer instance from the settings.

  11. val dispatcher: String
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  14. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  15. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. def getProperty(key: String): String

    Java API: Get a raw property.

    Java API: Get a raw property. null if it is not defined.

  17. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  18. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  19. val keyDeserializerOpt: Option[Deserializer[K]]
  20. val maxWakeups: Int
  21. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  22. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  23. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  24. val pollInterval: FiniteDuration
  25. val pollTimeout: FiniteDuration
  26. val properties: Map[String, String]
  27. val stopTimeout: FiniteDuration
  28. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  29. def toString(): String
    Definition Classes
    AnyRef → Any
  30. val valueDeserializerOpt: Option[Deserializer[V]]
  31. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  32. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  33. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  34. val waitClosePartition: FiniteDuration
  35. val wakeupDebug: Boolean
  36. val wakeupTimeout: FiniteDuration
  37. def withBootstrapServers(bootstrapServers: String): ConsumerSettings[K, V]
  38. def withClientId(clientId: String): ConsumerSettings[K, V]
  39. def withCloseTimeout(closeTimeout: FiniteDuration): ConsumerSettings[K, V]
  40. def withCommitRefreshInterval(commitRefreshInterval: Duration): ConsumerSettings[K, V]
  41. def withCommitTimeout(commitTimeout: FiniteDuration): ConsumerSettings[K, V]
  42. def withCommitWarning(commitTimeWarning: FiniteDuration): ConsumerSettings[K, V]
  43. def withDispatcher(dispatcher: String): ConsumerSettings[K, V]
  44. def withGroupId(groupId: String): ConsumerSettings[K, V]
  45. def withMaxWakeups(maxWakeups: Int): ConsumerSettings[K, V]
  46. def withPollInterval(pollInterval: FiniteDuration): ConsumerSettings[K, V]
  47. def withPollTimeout(pollTimeout: FiniteDuration): ConsumerSettings[K, V]
  48. def withProperties(properties: Map[String, String]): ConsumerSettings[K, V]

    The raw properties of the kafka-clients driver, see constants in org.apache.kafka.clients.consumer.ConsumerConfig.

  49. def withProperties(properties: (String, String)*): ConsumerSettings[K, V]

    The raw properties of the kafka-clients driver, see constants in org.apache.kafka.clients.consumer.ConsumerConfig.

  50. def withProperties(properties: Map[String, String]): ConsumerSettings[K, V]

    The raw properties of the kafka-clients driver, see constants in org.apache.kafka.clients.consumer.ConsumerConfig.

  51. def withProperty(key: String, value: String): ConsumerSettings[K, V]

    The raw properties of the kafka-clients driver, see constants in org.apache.kafka.clients.consumer.ConsumerConfig.

  52. def withStopTimeout(stopTimeout: FiniteDuration): ConsumerSettings[K, V]
  53. def withWaitClosePartition(waitClosePartition: FiniteDuration): ConsumerSettings[K, V]
  54. def withWakeupDebug(wakeupDebug: Boolean): ConsumerSettings[K, V]
  55. def withWakeupTimeout(wakeupTimeout: FiniteDuration): ConsumerSettings[K, V]

Inherited from AnyRef

Inherited from Any

Ungrouped