kafka.server

KafkaConfig

class KafkaConfig extends ZKConfig

Configuration settings for the kafka server

Linear Supertypes
ZKConfig, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. KafkaConfig
  2. ZKConfig
  3. AnyRef
  4. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new KafkaConfig(originalProps: Properties)

Value Members

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

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

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

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. val advertisedHostName: String

  7. val advertisedPort: Int

  8. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  9. val autoCreateTopicsEnable: Boolean

  10. val autoLeaderRebalanceEnable: Boolean

  11. val backgroundThreads: Int

  12. val brokerId: Int

  13. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  14. val connectionsMaxIdleMs: Long

  15. val controlledShutdownEnable: Boolean

  16. val controlledShutdownMaxRetries: Int

    Controlled shutdown can fail for multiple reasons.

    Controlled shutdown can fail for multiple reasons. This determines the number of retries when such failure happens

  17. val controlledShutdownRetryBackoffMs: Int

    Before each retry, the system needs time to recover from the state that caused the previous failure (Controller fail over, replica lag etc).

    Before each retry, the system needs time to recover from the state that caused the previous failure (Controller fail over, replica lag etc). This config determines the amount of time to wait before retrying.

  18. val controllerMessageQueueSize: Int

  19. val controllerSocketTimeoutMs: Int

  20. val defaultReplicationFactor: Int

  21. val deleteTopicEnable: Boolean

  22. final def eq(arg0: AnyRef): Boolean

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

    Definition Classes
    AnyRef → Any
  24. val fetchPurgatoryPurgeIntervalRequests: Int

  25. def finalize(): Unit

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

    Definition Classes
    AnyRef → Any
  27. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  28. val hostName: String

  29. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  30. val leaderImbalanceCheckIntervalSeconds: Int

  31. val leaderImbalancePerBrokerPercentage: Int

  32. val logCleanerBackoffMs: Long

  33. val logCleanerDedupeBufferLoadFactor: Double

  34. val logCleanerDedupeBufferSize: Long

  35. val logCleanerDeleteRetentionMs: Long

  36. val logCleanerEnable: Boolean

  37. val logCleanerIoBufferSize: Int

  38. val logCleanerIoMaxBytesPerSecond: Double

  39. val logCleanerMinCleanRatio: Double

  40. val logCleanerThreads: Int

  41. val logCleanupIntervalMs: Long

  42. val logCleanupPolicy: String

  43. val logDeleteDelayMs: Long

  44. val logDirs: Seq[String]

  45. val logFlushIntervalMessages: Long

  46. val logFlushIntervalMs: Long

  47. val logFlushOffsetCheckpointIntervalMs: Int

  48. val logFlushSchedulerIntervalMs: Long

  49. val logIndexIntervalBytes: Int

  50. val logIndexSizeMaxBytes: Int

  51. val logRetentionBytes: Long

  52. val logRetentionTimeMillis: Long

  53. val logRollTimeJitterMillis: Long

  54. val logRollTimeMillis: Long

  55. val logSegmentBytes: Int

  56. val maxConnectionsPerIp: Int

  57. val maxConnectionsPerIpOverrides: Map[String, Int]

  58. val messageMaxBytes: Int

  59. val minInSyncReplicas: Int

  60. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  61. final def notify(): Unit

    Definition Classes
    AnyRef
  62. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  63. val numIoThreads: Int

  64. val numNetworkThreads: Int

  65. val numPartitions: Int

  66. val numRecoveryThreadsPerDataDir: Int

  67. val numReplicaFetchers: Int

  68. val offsetCommitRequiredAcks: Short

    The required acks before the commit can be accepted.

    The required acks before the commit can be accepted. In general, the default (-1) should not be overridden.

  69. val offsetCommitTimeoutMs: Int

  70. val offsetMetadataMaxSize: Int

  71. val offsetsLoadBufferSize: Int

    Batch size for reading from the offsets segments when loading offsets into the cache.

  72. val offsetsRetentionCheckIntervalMs: Long

    Frequency at which to check for stale offsets.

  73. val offsetsRetentionMinutes: Int

    Offsets older than this retention period will be discarded.

  74. val offsetsTopicCompressionCodec: CompressionCodec

    Compression codec for the offsets topic - compression may be used to achieve "atomic" commits.

  75. val offsetsTopicPartitions: Int

    The number of partitions for the offset commit topic (should not change after deployment).

  76. val offsetsTopicReplicationFactor: Short

    The replication factor for the offsets topic (set higher to ensure availability).

    The replication factor for the offsets topic (set higher to ensure availability). To ensure that the effective replication factor of the offsets topic is the configured value, the number of alive brokers has to be at least the replication factor at the time of the first request for the offsets topic. If not, either the offsets topic creation will fail or it will get a replication factor of min(alive brokers, configured replication factor)

  77. val offsetsTopicSegmentBytes: Int

    The offsets topic segment bytes should be kept relatively small in order to facilitate faster log compaction and cache loads

  78. val port: Int

  79. val producerPurgatoryPurgeIntervalRequests: Int

  80. val props: VerifiableProperties

  81. val queuedMaxRequests: Int

  82. val replicaFetchMaxBytes: Int

  83. val replicaFetchMinBytes: Int

  84. val replicaFetchWaitMaxMs: Int

  85. val replicaHighWatermarkCheckpointIntervalMs: Long

  86. val replicaLagMaxMessages: Long

  87. val replicaLagTimeMaxMs: Long

  88. val replicaSocketReceiveBufferBytes: Int

  89. val replicaSocketTimeoutMs: Int

  90. val socketReceiveBufferBytes: Int

  91. val socketRequestMaxBytes: Int

  92. val socketSendBufferBytes: Int

  93. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  94. def toString(): String

    Definition Classes
    AnyRef → Any
  95. val uncleanLeaderElectionEnable: Boolean

  96. final def wait(): Unit

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

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

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

    ZK host string

    ZK host string

    Definition Classes
    ZKConfig
  100. val zkConnectionTimeoutMs: Int

    the max time that the client waits to establish a connection to zookeeper

    the max time that the client waits to establish a connection to zookeeper

    Definition Classes
    ZKConfig
  101. val zkSessionTimeoutMs: Int

    zookeeper session timeout

    zookeeper session timeout

    Definition Classes
    ZKConfig
  102. val zkSyncTimeMs: Int

    how far a ZK follower can be behind a ZK leader

    how far a ZK follower can be behind a ZK leader

    Definition Classes
    ZKConfig

Inherited from ZKConfig

Inherited from AnyRef

Inherited from Any

Ungrouped