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