kafka.server

KafkaConfig

class KafkaConfig extends AbstractConfig

Linear Supertypes
AbstractConfig, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. KafkaConfig
  2. AbstractConfig
  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(props: Map[_, _])

  2. new KafkaConfig(props: Map[_, _], doLog: Boolean)

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 advertisedListeners: Map[SecurityProtocol, EndPoint]

  8. val advertisedPort: Integer

  9. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  10. val authorizerClassName: String

    *********** Authorizer Configuration **********

  11. val autoCreateTopicsEnable: Boolean

    ********* Log Configuration **********

  12. val autoLeaderRebalanceEnable: Boolean

  13. val backgroundThreads: Integer

  14. var brokerId: Int

  15. val brokerIdGenerationEnable: Boolean

    ********* General Configuration **********

  16. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  17. val compressionType: String

  18. val connectionsMaxIdleMs: Long

  19. val consumerQuotaBytesPerSecondDefault: Long

  20. val controlledShutdownEnable: Boolean

  21. val controlledShutdownMaxRetries: Integer

    ********* Controlled shutdown configuration **********

  22. val controlledShutdownRetryBackoffMs: Long

  23. val controllerSocketTimeoutMs: Int

    ********* Replication configuration **********

  24. val defaultReplicationFactor: Int

  25. val deleteTopicEnable: Boolean

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

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

    Definition Classes
    AbstractConfig → AnyRef → Any
  28. val fetchPurgatoryPurgeIntervalRequests: Integer

  29. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  30. def get(arg0: String): AnyRef

    Attributes
    protected[org.apache.kafka.common.config]
    Definition Classes
    AbstractConfig
  31. def getBoolean(arg0: String): Boolean

    Definition Classes
    AbstractConfig
  32. def getClass(arg0: String): Class[_]

    Definition Classes
    AbstractConfig
  33. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  34. def getConfiguredInstance[T](arg0: String, arg1: Class[T]): T

    Definition Classes
    AbstractConfig
  35. def getConfiguredInstances[T](arg0: String, arg1: Class[T]): List[T]

    Definition Classes
    AbstractConfig
  36. def getDouble(arg0: String): Double

    Definition Classes
    AbstractConfig
  37. def getInt(arg0: String): Integer

    Definition Classes
    AbstractConfig
  38. def getList(arg0: String): List[String]

    Definition Classes
    AbstractConfig
  39. def getLong(arg0: String): Long

    Definition Classes
    AbstractConfig
  40. def getPassword(arg0: String): Password

    Definition Classes
    AbstractConfig
  41. def getShort(arg0: String): Short

    Definition Classes
    AbstractConfig
  42. def getString(arg0: String): String

    Definition Classes
    AbstractConfig
  43. val groupMaxSessionTimeoutMs: Integer

  44. val groupMinSessionTimeoutMs: Integer

    ********* Group coordinator configuration **********

  45. def hashCode(): Int

    Definition Classes
    AbstractConfig → AnyRef → Any
  46. val hostName: String

    ********* Socket Server Configuration **********

  47. def ignore(arg0: String): Unit

    Definition Classes
    AbstractConfig
  48. val interBrokerProtocolVersion: ApiVersion

  49. val interBrokerSecurityProtocol: SecurityProtocol

  50. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  51. val leaderImbalanceCheckIntervalSeconds: Long

  52. val leaderImbalancePerBrokerPercentage: Integer

  53. val listeners: Map[SecurityProtocol, EndPoint]

  54. val logCleanerBackoffMs: Long

  55. val logCleanerDedupeBufferLoadFactor: Double

  56. val logCleanerDedupeBufferSize: Long

  57. val logCleanerDeleteRetentionMs: Long

  58. val logCleanerEnable: Boolean

  59. val logCleanerIoBufferSize: Integer

  60. val logCleanerIoMaxBytesPerSecond: Double

  61. val logCleanerMinCleanRatio: Double

  62. val logCleanerThreads: Integer

  63. val logCleanupIntervalMs: Long

  64. val logCleanupPolicy: String

  65. val logDeleteDelayMs: Long

  66. val logDirs: Seq[String]

  67. val logFlushIntervalMessages: Long

  68. val logFlushIntervalMs: Long

  69. val logFlushOffsetCheckpointIntervalMs: Long

  70. val logFlushSchedulerIntervalMs: Long

  71. val logIndexIntervalBytes: Integer

  72. val logIndexSizeMaxBytes: Integer

  73. val logPreAllocateEnable: Boolean

  74. val logRetentionBytes: Long

  75. val logRetentionTimeMillis: Long

  76. val logRollTimeJitterMillis: Long

  77. val logRollTimeMillis: Long

  78. val logSegmentBytes: Integer

  79. def logUnused(): Unit

    Definition Classes
    AbstractConfig
  80. val maxConnectionsPerIp: Integer

  81. val maxConnectionsPerIpOverrides: Map[String, Int]

  82. val maxReservedBrokerId: Int

  83. val messageMaxBytes: Integer

  84. val metricNumSamples: Integer

    ********* Metric Configuration *************

  85. val metricReporterClasses: List[MetricsReporter]

  86. val metricSampleWindowMs: Long

  87. val minInSyncReplicas: Integer

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

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

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

    Definition Classes
    AnyRef
  91. val numIoThreads: Integer

  92. val numNetworkThreads: Integer

  93. val numPartitions: Integer

  94. val numQuotaSamples: Integer

  95. val numRecoveryThreadsPerDataDir: Integer

  96. val numReplicaFetchers: Integer

  97. val offsetCommitRequiredAcks: Short

  98. val offsetCommitTimeoutMs: Integer

  99. val offsetMetadataMaxSize: Integer

    ********* Offset management configuration **********

  100. val offsetsLoadBufferSize: Integer

  101. val offsetsRetentionCheckIntervalMs: Long

  102. val offsetsRetentionMinutes: Integer

  103. val offsetsTopicCompressionCodec: CompressionCodec

  104. val offsetsTopicPartitions: Integer

  105. val offsetsTopicReplicationFactor: Short

  106. val offsetsTopicSegmentBytes: Integer

  107. def originals(): Map[String, AnyRef]

    Definition Classes
    AbstractConfig
  108. def originalsStrings(): Map[String, String]

    Definition Classes
    AbstractConfig
  109. def originalsWithPrefix(arg0: String): Map[String, AnyRef]

    Definition Classes
    AbstractConfig
  110. val port: Integer

  111. val principalBuilderClass: Class[_]

    ********* SSL Configuration *************

  112. val producerPurgatoryPurgeIntervalRequests: Integer

  113. val producerQuotaBytesPerSecondDefault: Long

    ********* Quota Configuration *************

  114. val props: Map[_, _]

  115. val queuedMaxRequests: Integer

  116. val quotaWindowSizeSeconds: Integer

  117. val replicaFetchBackoffMs: Integer

  118. val replicaFetchMaxBytes: Integer

  119. val replicaFetchMinBytes: Integer

  120. val replicaFetchWaitMaxMs: Integer

  121. val replicaHighWatermarkCheckpointIntervalMs: Long

  122. val replicaLagTimeMaxMs: Long

  123. val replicaSocketReceiveBufferBytes: Integer

  124. val replicaSocketTimeoutMs: Integer

  125. val requestTimeoutMs: Integer

  126. val saslKerberosKinitCmd: String

  127. val saslKerberosMinTimeBeforeRelogin: Long

  128. val saslKerberosPrincipalToLocalRules: List[String]

  129. val saslKerberosServiceName: String

    ********* Sasl Configuration *************

  130. val saslKerberosTicketRenewJitter: Double

  131. val saslKerberosTicketRenewWindowFactor: Double

  132. val socketReceiveBufferBytes: Integer

  133. val socketRequestMaxBytes: Integer

  134. val socketSendBufferBytes: Integer

  135. val sslCipher: List[String]

  136. val sslClientAuth: String

  137. val sslEnabledProtocols: List[String]

  138. val sslKeyManagerAlgorithm: String

  139. val sslKeyPassword: Password

  140. val sslKeystoreLocation: String

  141. val sslKeystorePassword: Password

  142. val sslKeystoreType: String

  143. val sslProtocol: String

  144. val sslProvider: String

  145. val sslTrustManagerAlgorithm: String

  146. val sslTruststoreLocation: String

  147. val sslTruststorePassword: Password

  148. val sslTruststoreType: String

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

    Definition Classes
    AnyRef
  150. def toString(): String

    Definition Classes
    AnyRef → Any
  151. val uncleanLeaderElectionEnable: Boolean

  152. def unused(): Set[String]

    Definition Classes
    AbstractConfig
  153. def values(): Map[String, _]

    Definition Classes
    AbstractConfig
  154. final def wait(): Unit

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

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

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

    ********* Zookeeper Configuration **********

  158. val zkConnectionTimeoutMs: Int

  159. val zkEnableSecureAcls: Boolean

  160. val zkSessionTimeoutMs: Int

  161. val zkSyncTimeMs: Int

Inherited from AbstractConfig

Inherited from AnyRef

Inherited from Any

Ungrouped