kafka.server

KafkaConfig

object KafkaConfig

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

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 AdvertisedHostNameDoc: String

  7. val AdvertisedHostNameProp: String

  8. val AdvertisedListenersDoc: String

  9. val AdvertisedListenersProp: String

  10. val AdvertisedPortDoc: String

  11. val AdvertisedPortProp: String

  12. val AuthorizerClassNameDoc: String

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

  13. val AuthorizerClassNameProp: String

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

  14. val AutoCreateTopicsEnableDoc: String

  15. val AutoCreateTopicsEnableProp: String

  16. val AutoLeaderRebalanceEnableDoc: String

  17. val AutoLeaderRebalanceEnableProp: String

  18. val BackgroundThreadsDoc: String

  19. val BackgroundThreadsProp: String

  20. val BrokerIdDoc: String

  21. val BrokerIdGenerationEnableDoc: String

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

  22. val BrokerIdGenerationEnableProp: String

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

  23. val BrokerIdProp: String

  24. val CompressionTypeDoc: String

  25. val CompressionTypeProp: String

  26. val ConnectionsMaxIdleMsDoc: String

  27. val ConnectionsMaxIdleMsProp: String

  28. val ConsumerMaxSessionTimeoutMsDoc: String

  29. val ConsumerMinSessionTimeoutMsDoc: String

    ********* Consumer coordinator configuration **********

  30. val ConsumerQuotaBytesPerSecondDefaultDoc: String

  31. val ConsumerQuotaBytesPerSecondDefaultProp: String

  32. val ControlledShutdownEnableDoc: String

  33. val ControlledShutdownEnableProp: String

  34. val ControlledShutdownMaxRetriesDoc: String

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

  35. val ControlledShutdownMaxRetriesProp: String

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

  36. val ControlledShutdownRetryBackoffMsDoc: String

  37. val ControlledShutdownRetryBackoffMsProp: String

  38. val ControllerMessageQueueSizeDoc: String

  39. val ControllerSocketTimeoutMsDoc: String

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

  40. val ControllerSocketTimeoutMsProp: String

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

  41. val DefaultReplicationFactorDoc: String

  42. val DefaultReplicationFactorProp: String

  43. val DeleteTopicEnableDoc: String

  44. val DeleteTopicEnableProp: String

  45. val FetchPurgatoryPurgeIntervalRequestsDoc: String

  46. val FetchPurgatoryPurgeIntervalRequestsProp: String

  47. val GroupMaxSessionTimeoutMsProp: String

  48. val GroupMinSessionTimeoutMsProp: String

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

  49. val HostNameDoc: String

  50. val HostNameProp: String

  51. val InterBrokerProtocolVersionDoc: String

  52. val InterBrokerProtocolVersionProp: String

  53. val InterBrokerSecurityProtocolDoc: String

  54. val InterBrokerSecurityProtocolProp: String

  55. val LeaderImbalanceCheckIntervalSecondsDoc: String

  56. val LeaderImbalanceCheckIntervalSecondsProp: String

  57. val LeaderImbalancePerBrokerPercentageDoc: String

  58. val LeaderImbalancePerBrokerPercentageProp: String

  59. val ListenersDoc: String

  60. val ListenersProp: String

  61. val LogCleanerBackoffMsDoc: String

  62. val LogCleanerBackoffMsProp: String

  63. val LogCleanerDedupeBufferLoadFactorDoc: String

  64. val LogCleanerDedupeBufferLoadFactorProp: String

  65. val LogCleanerDedupeBufferSizeDoc: String

  66. val LogCleanerDedupeBufferSizeProp: String

  67. val LogCleanerDeleteRetentionMsDoc: String

  68. val LogCleanerDeleteRetentionMsProp: String

  69. val LogCleanerEnableDoc: String

  70. val LogCleanerEnableProp: String

  71. val LogCleanerIoBufferSizeDoc: String

  72. val LogCleanerIoBufferSizeProp: String

  73. val LogCleanerIoMaxBytesPerSecondDoc: String

  74. val LogCleanerIoMaxBytesPerSecondProp: String

  75. val LogCleanerMinCleanRatioDoc: String

  76. val LogCleanerMinCleanRatioProp: String

  77. val LogCleanerThreadsDoc: String

  78. val LogCleanerThreadsProp: String

  79. val LogCleanupIntervalMsDoc: String

  80. val LogCleanupIntervalMsProp: String

  81. val LogCleanupPolicyDoc: String

  82. val LogCleanupPolicyProp: String

  83. val LogDeleteDelayMsDoc: String

  84. val LogDeleteDelayMsProp: String

  85. val LogDirDoc: String

  86. val LogDirProp: String

  87. val LogDirsDoc: String

  88. val LogDirsProp: String

  89. val LogFlushIntervalMessagesDoc: String

  90. val LogFlushIntervalMessagesProp: String

  91. val LogFlushIntervalMsDoc: String

  92. val LogFlushIntervalMsProp: String

  93. val LogFlushOffsetCheckpointIntervalMsDoc: String

  94. val LogFlushOffsetCheckpointIntervalMsProp: String

  95. val LogFlushSchedulerIntervalMsDoc: String

  96. val LogFlushSchedulerIntervalMsProp: String

  97. val LogIndexIntervalBytesDoc: String

  98. val LogIndexIntervalBytesProp: String

  99. val LogIndexSizeMaxBytesDoc: String

  100. val LogIndexSizeMaxBytesProp: String

  101. val LogPreAllocateEnableDoc: String

  102. val LogPreAllocateProp: String

  103. val LogRetentionBytesDoc: String

  104. val LogRetentionBytesProp: String

  105. val LogRetentionTimeHoursDoc: String

  106. val LogRetentionTimeHoursProp: String

  107. val LogRetentionTimeMillisDoc: String

  108. val LogRetentionTimeMillisProp: String

  109. val LogRetentionTimeMinsDoc: String

  110. val LogRetentionTimeMinutesProp: String

  111. val LogRollTimeHoursDoc: String

  112. val LogRollTimeHoursProp: String

  113. val LogRollTimeJitterHoursDoc: String

  114. val LogRollTimeJitterHoursProp: String

  115. val LogRollTimeJitterMillisDoc: String

  116. val LogRollTimeJitterMillisProp: String

  117. val LogRollTimeMillisDoc: String

  118. val LogRollTimeMillisProp: String

  119. val LogSegmentBytesDoc: String

  120. val LogSegmentBytesProp: String

  121. val MaxConnectionsPerIpDoc: String

  122. val MaxConnectionsPerIpOverridesDoc: String

  123. val MaxConnectionsPerIpOverridesProp: String

  124. val MaxConnectionsPerIpProp: String

  125. val MaxReservedBrokerIdDoc: String

  126. val MaxReservedBrokerIdProp: String

  127. val MessageMaxBytesDoc: String

  128. val MessageMaxBytesProp: String

  129. val MetricNumSamplesDoc: String

  130. val MetricNumSamplesProp: String

  131. val MetricReporterClassesDoc: String

  132. val MetricReporterClassesProp: String

  133. val MetricSampleWindowMsDoc: String

    ********* Kafka Metrics Configuration **********

  134. val MetricSampleWindowMsProp: String

    ********* Kafka Metrics Configuration **********

  135. val MinInSyncReplicasDoc: String

  136. val MinInSyncReplicasProp: String

  137. val NumIoThreadsDoc: String

  138. val NumIoThreadsProp: String

  139. val NumNetworkThreadsDoc: String

  140. val NumNetworkThreadsProp: String

  141. val NumPartitionsDoc: String

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

  142. val NumPartitionsProp: String

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

  143. val NumQuotaSamplesDoc: String

  144. val NumQuotaSamplesProp: String

  145. val NumRecoveryThreadsPerDataDirDoc: String

  146. val NumRecoveryThreadsPerDataDirProp: String

  147. val NumReplicaFetchersDoc: String

  148. val NumReplicaFetchersProp: String

  149. val OffsetCommitRequiredAcksDoc: String

  150. val OffsetCommitRequiredAcksProp: String

  151. val OffsetCommitTimeoutMsDoc: String

  152. val OffsetCommitTimeoutMsProp: String

  153. val OffsetMetadataMaxSizeDoc: String

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

  154. val OffsetMetadataMaxSizeProp: String

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

  155. val OffsetsLoadBufferSizeDoc: String

  156. val OffsetsLoadBufferSizeProp: String

  157. val OffsetsRetentionCheckIntervalMsDoc: String

  158. val OffsetsRetentionCheckIntervalMsProp: String

  159. val OffsetsRetentionMinutesDoc: String

  160. val OffsetsRetentionMinutesProp: String

  161. val OffsetsTopicCompressionCodecDoc: String

  162. val OffsetsTopicCompressionCodecProp: String

  163. val OffsetsTopicPartitionsDoc: String

  164. val OffsetsTopicPartitionsProp: String

  165. val OffsetsTopicReplicationFactorDoc: String

  166. val OffsetsTopicReplicationFactorProp: String

  167. val OffsetsTopicSegmentBytesDoc: String

  168. val OffsetsTopicSegmentBytesProp: String

  169. val PortDoc: String

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

  170. val PortProp: String

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

  171. val PrincipalBuilderClassDoc: String

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

  172. val PrincipalBuilderClassProp: String

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

  173. val ProducerPurgatoryPurgeIntervalRequestsDoc: String

  174. val ProducerPurgatoryPurgeIntervalRequestsProp: String

  175. val ProducerQuotaBytesPerSecondDefaultDoc: String

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

  176. val ProducerQuotaBytesPerSecondDefaultProp: String

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

  177. val QueuedMaxRequestsDoc: String

  178. val QueuedMaxRequestsProp: String

  179. val QuotaWindowSizeSecondsDoc: String

  180. val QuotaWindowSizeSecondsProp: String

  181. val ReplicaFetchBackoffMsDoc: String

  182. val ReplicaFetchBackoffMsProp: String

  183. val ReplicaFetchMaxBytesDoc: String

  184. val ReplicaFetchMaxBytesProp: String

  185. val ReplicaFetchMinBytesDoc: String

  186. val ReplicaFetchMinBytesProp: String

  187. val ReplicaFetchWaitMaxMsDoc: String

  188. val ReplicaFetchWaitMaxMsProp: String

  189. val ReplicaHighWatermarkCheckpointIntervalMsDoc: String

  190. val ReplicaHighWatermarkCheckpointIntervalMsProp: String

  191. val ReplicaLagTimeMaxMsDoc: String

  192. val ReplicaLagTimeMaxMsProp: String

  193. val ReplicaSocketReceiveBufferBytesDoc: String

  194. val ReplicaSocketReceiveBufferBytesProp: String

  195. val ReplicaSocketTimeoutMsDoc: String

  196. val ReplicaSocketTimeoutMsProp: String

  197. val RequestTimeoutMsDoc: String

  198. val RequestTimeoutMsProp: String

  199. val SaslKerberosKinitCmdDoc: String

  200. val SaslKerberosKinitCmdProp: String

  201. val SaslKerberosMinTimeBeforeReloginDoc: String

  202. val SaslKerberosMinTimeBeforeReloginProp: String

  203. val SaslKerberosPrincipalToLocalRulesDoc: String

  204. val SaslKerberosPrincipalToLocalRulesProp: String

  205. val SaslKerberosServiceNameDoc: String

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

  206. val SaslKerberosServiceNameProp: String

    ********* SASL Configuration ***************

  207. val SaslKerberosTicketRenewJitterDoc: String

  208. val SaslKerberosTicketRenewJitterProp: String

  209. val SaslKerberosTicketRenewWindowFactorDoc: String

  210. val SaslKerberosTicketRenewWindowFactorProp: String

  211. val SocketReceiveBufferBytesDoc: String

  212. val SocketReceiveBufferBytesProp: String

  213. val SocketRequestMaxBytesDoc: String

  214. val SocketRequestMaxBytesProp: String

  215. val SocketSendBufferBytesDoc: String

  216. val SocketSendBufferBytesProp: String

  217. val SslCipherSuitesDoc: String

  218. val SslCipherSuitesProp: String

  219. val SslClientAuthDoc: String

  220. val SslClientAuthProp: String

  221. val SslEnabledProtocolsDoc: String

  222. val SslEnabledProtocolsProp: String

  223. val SslEndpointIdentificationAlgorithmDoc: String

  224. val SslEndpointIdentificationAlgorithmProp: String

  225. val SslKeyManagerAlgorithmDoc: String

  226. val SslKeyManagerAlgorithmProp: String

  227. val SslKeyPasswordDoc: String

  228. val SslKeyPasswordProp: String

  229. val SslKeystoreLocationDoc: String

  230. val SslKeystoreLocationProp: String

  231. val SslKeystorePasswordDoc: String

  232. val SslKeystorePasswordProp: String

  233. val SslKeystoreTypeDoc: String

  234. val SslKeystoreTypeProp: String

  235. val SslProtocolDoc: String

  236. val SslProtocolProp: String

  237. val SslProviderDoc: String

  238. val SslProviderProp: String

  239. val SslTrustManagerAlgorithmDoc: String

  240. val SslTrustManagerAlgorithmProp: String

  241. val SslTruststoreLocationDoc: String

  242. val SslTruststoreLocationProp: String

  243. val SslTruststorePasswordDoc: String

  244. val SslTruststorePasswordProp: String

  245. val SslTruststoreTypeDoc: String

  246. val SslTruststoreTypeProp: String

  247. val UncleanLeaderElectionEnableDoc: String

  248. val UncleanLeaderElectionEnableProp: String

  249. val ZkConnectDoc: String

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

  250. val ZkConnectProp: String

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

  251. val ZkConnectionTimeoutMsDoc: String

  252. val ZkConnectionTimeoutMsProp: String

  253. val ZkEnableSecureAclsDoc: String

  254. val ZkEnableSecureAclsProp: String

  255. val ZkSessionTimeoutMsDoc: String

  256. val ZkSessionTimeoutMsProp: String

  257. val ZkSyncTimeMsDoc: String

  258. val ZkSyncTimeMsProp: String

  259. def apply(props: Map[_, _]): KafkaConfig

  260. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  261. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  262. def configNames(): List[String]

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

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

    Definition Classes
    AnyRef → Any
  265. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  266. def fromProps(defaults: Properties, overrides: Properties, doLog: Boolean): KafkaConfig

  267. def fromProps(defaults: Properties, overrides: Properties): KafkaConfig

  268. def fromProps(props: Properties, doLog: Boolean): KafkaConfig

  269. def fromProps(props: Properties): KafkaConfig

  270. final def getClass(): Class[_]

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

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

    Definition Classes
    Any
  273. def main(args: Array[String]): Unit

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

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

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

    Definition Classes
    AnyRef
  277. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  278. def toString(): String

    Definition Classes
    AnyRef → Any
  279. def validateNames(props: Properties): Unit

    Check that property names are valid

  280. final def wait(): Unit

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped