kafka.server

Defaults

object Defaults

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Defaults
  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 AuthorizerClassName: String

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

  7. val AutoCreateTopicsEnable: Boolean

  8. val AutoLeaderRebalanceEnable: Boolean

  9. val BackgroundThreads: Int

  10. val BrokerId: Int

  11. val Compact: String

  12. val CompressionType: String

  13. val ConnectionsMaxIdleMs: Long

  14. val ConsumerMaxSessionTimeoutMs: Int

  15. val ConsumerMinSessionTimeoutMs: Int

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

  16. val ConsumerQuotaBytesPerSecondDefault: Long

  17. val ControlledShutdownEnable: Boolean

  18. val ControlledShutdownMaxRetries: Int

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

  19. val ControlledShutdownRetryBackoffMs: Int

  20. val ControllerMessageQueueSize: Int

  21. val ControllerSocketTimeoutMs: Int

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

  22. val DefaultReplicationFactor: Int

  23. val Delete: String

  24. val DeleteTopicEnable: Boolean

  25. val FetchPurgatoryPurgeIntervalRequests: Int

  26. val HostName: String

  27. val InterBrokerProtocolVersion: String

  28. val InterBrokerSecurityProtocol: String

  29. val LeaderImbalanceCheckIntervalSeconds: Int

  30. val LeaderImbalancePerBrokerPercentage: Int

  31. val LogCleanerBackoffMs: Int

  32. val LogCleanerDedupeBufferLoadFactor: Double

  33. val LogCleanerDedupeBufferSize: Long

  34. val LogCleanerDeleteRetentionMs: Long

  35. val LogCleanerEnable: Boolean

  36. val LogCleanerIoBufferSize: Int

  37. val LogCleanerIoMaxBytesPerSecond: Double

  38. val LogCleanerMinCleanRatio: Double

  39. val LogCleanerThreads: Int

  40. val LogCleanupIntervalMs: Long

  41. val LogCleanupPolicy: String

  42. val LogDeleteDelayMs: Int

  43. val LogDir: String

  44. val LogFlushIntervalMessages: Long

  45. val LogFlushOffsetCheckpointIntervalMs: Int

  46. val LogFlushSchedulerIntervalMs: Long

  47. val LogIndexIntervalBytes: Int

  48. val LogIndexSizeMaxBytes: Int

  49. val LogPreAllocateEnable: Boolean

  50. val LogRetentionBytes: Long

  51. val LogRetentionHours: Int

  52. val LogRollHours: Int

  53. val LogRollJitterHours: Int

  54. val LogSegmentBytes: Int

  55. val MaxConnectionsPerIp: Int

  56. val MaxConnectionsPerIpOverrides: String

  57. val MaxReservedBrokerId: Int

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

  58. val MessageMaxBytes: Int

  59. val MetricNumSamples: Int

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

  60. val MetricReporterClasses: String

  61. val MetricSampleWindowMs: Int

  62. val MinInSyncReplicas: Int

  63. val NumIoThreads: Int

  64. val NumNetworkThreads: Int

  65. val NumPartitions: Int

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

  66. val NumQuotaSamples: Int

  67. val NumRecoveryThreadsPerDataDir: Int

  68. val NumReplicaFetchers: Int

  69. val OffsetCommitRequiredAcks: Short

  70. val OffsetCommitTimeoutMs: Int

  71. val OffsetMetadataMaxSize: Int

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

  72. val OffsetsLoadBufferSize: Int

  73. val OffsetsRetentionCheckIntervalMs: Long

  74. val OffsetsRetentionMinutes: Int

  75. val OffsetsTopicCompressionCodec: Int

  76. val OffsetsTopicPartitions: Int

  77. val OffsetsTopicReplicationFactor: Short

  78. val OffsetsTopicSegmentBytes: Int

  79. val Port: Int

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

  80. val PrincipalBuilderClass: String

    ********* SSL configuration **********

  81. val ProducerPurgatoryPurgeIntervalRequests: Int

  82. val ProducerQuotaBytesPerSecondDefault: Long

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

  83. val QueuedMaxRequests: Int

  84. val QuotaWindowSizeSeconds: Int

  85. val ReplicaFetchBackoffMs: Int

  86. val ReplicaFetchMaxBytes: Int

  87. val ReplicaFetchMinBytes: Int

  88. val ReplicaFetchWaitMaxMs: Int

  89. val ReplicaHighWatermarkCheckpointIntervalMs: Long

  90. val ReplicaLagTimeMaxMs: Long

  91. val ReplicaSocketReceiveBufferBytes: Int

  92. val ReplicaSocketTimeoutMs: Int

  93. val RequestTimeoutMs: Int

  94. val SaslKerberosKinitCmd: String

    ********* Sasl configuration **********

  95. val SaslKerberosMinTimeBeforeRelogin: Long

  96. val SaslKerberosPrincipalToLocalRules: List[String]

  97. val SaslKerberosTicketRenewJitter: Double

  98. val SaslKerberosTicketRenewWindowFactor: Double

  99. val SocketReceiveBufferBytes: Int

  100. val SocketRequestMaxBytes: Int

  101. val SocketSendBufferBytes: Int

  102. val SslClientAuth: String

  103. val SslClientAuthNone: String

  104. val SslClientAuthRequested: String

  105. val SslClientAuthRequired: String

  106. val SslEnabledProtocols: String

  107. val SslKeyManagerAlgorithm: String

  108. val SslKeystoreType: String

  109. val SslProtocol: String

  110. val SslTrustManagerAlgorithm: String

  111. val SslTruststoreType: String

  112. val UncleanLeaderElectionEnable: Boolean

  113. val ZkEnableSecureAcls: Boolean

  114. val ZkSessionTimeoutMs: Int

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

  115. val ZkSyncTimeMs: Int

  116. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  117. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  118. final def eq(arg0: AnyRef): Boolean

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

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

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

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

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

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

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

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

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

    Definition Classes
    AnyRef
  128. def toString(): String

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

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped