Class/Object

org.apache.spark.streaming.kafka.KafkaCluster

SimpleConsumerConfig

Related Docs: object SimpleConsumerConfig | package KafkaCluster

Permalink

class SimpleConsumerConfig extends ConsumerConfig

High-level kafka consumers connect to ZK. ConsumerConfig assumes this use case. Simple consumers connect directly to brokers, but need many of the same configs. This subclass won't warn about missing ZK params, or presence of broker params.

Source
KafkaCluster.scala
Linear Supertypes
ConsumerConfig, ZKConfig, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SimpleConsumerConfig
  2. ConsumerConfig
  3. ZKConfig
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  5. val autoCommitEnable: Boolean

    Permalink
    Definition Classes
    ConsumerConfig
  6. val autoCommitIntervalMs: Int

    Permalink
    Definition Classes
    ConsumerConfig
  7. val autoOffsetReset: String

    Permalink
    Definition Classes
    ConsumerConfig
  8. val clientId: String

    Permalink
    Definition Classes
    ConsumerConfig
  9. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  10. val consumerId: Option[String]

    Permalink
    Definition Classes
    ConsumerConfig
  11. val consumerTimeoutMs: Int

    Permalink
    Definition Classes
    ConsumerConfig
  12. val dualCommitEnabled: Boolean

    Permalink
    Definition Classes
    ConsumerConfig
  13. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  14. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  15. val excludeInternalTopics: Boolean

    Permalink
    Definition Classes
    ConsumerConfig
  16. val fetchMessageMaxBytes: Int

    Permalink
    Definition Classes
    ConsumerConfig
  17. val fetchMinBytes: Int

    Permalink
    Definition Classes
    ConsumerConfig
  18. val fetchWaitMaxMs: Int

    Permalink
    Definition Classes
    ConsumerConfig
  19. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  20. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  21. val groupId: String

    Permalink
    Definition Classes
    ConsumerConfig
  22. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  23. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  24. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  25. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  26. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  27. val numConsumerFetchers: Int

    Permalink
    Definition Classes
    ConsumerConfig
  28. val offsetsChannelBackoffMs: Int

    Permalink
    Definition Classes
    ConsumerConfig
  29. val offsetsChannelSocketTimeoutMs: Int

    Permalink
    Definition Classes
    ConsumerConfig
  30. val offsetsCommitMaxRetries: Int

    Permalink
    Definition Classes
    ConsumerConfig
  31. val offsetsStorage: String

    Permalink
    Definition Classes
    ConsumerConfig
  32. val partitionAssignmentStrategy: String

    Permalink
    Definition Classes
    ConsumerConfig
  33. val props: VerifiableProperties

    Permalink
    Definition Classes
    ConsumerConfig
  34. val queuedMaxMessages: Int

    Permalink
    Definition Classes
    ConsumerConfig
  35. val rebalanceBackoffMs: Int

    Permalink
    Definition Classes
    ConsumerConfig
  36. val rebalanceMaxRetries: Int

    Permalink
    Definition Classes
    ConsumerConfig
  37. val refreshLeaderBackoffMs: Int

    Permalink
    Definition Classes
    ConsumerConfig
  38. val seedBrokers: Array[(String, Int)]

    Permalink
  39. val socketReceiveBufferBytes: Int

    Permalink
    Definition Classes
    ConsumerConfig
  40. val socketTimeoutMs: Int

    Permalink
    Definition Classes
    ConsumerConfig
  41. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  42. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  43. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  44. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  45. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  46. val zkConnect: String

    Permalink
    Definition Classes
    ZKConfig
  47. val zkConnectionTimeoutMs: Int

    Permalink
    Definition Classes
    ZKConfig
  48. val zkSessionTimeoutMs: Int

    Permalink
    Definition Classes
    ZKConfig
  49. val zkSyncTimeMs: Int

    Permalink
    Definition Classes
    ZKConfig

Inherited from ConsumerConfig

Inherited from ZKConfig

Inherited from AnyRef

Inherited from Any

Ungrouped