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 BrokerIdGenerationEnable: Boolean

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

  12. val Compact: String

  13. val CompressionType: String

  14. val ConnectionsMaxIdleMs: Long

  15. val ConsumerMaxSessionTimeoutMs: Int

  16. val ConsumerMinSessionTimeoutMs: Int

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

  17. val ConsumerQuotaBytesPerSecondDefault: Long

  18. val ControlledShutdownEnable: Boolean

  19. val ControlledShutdownMaxRetries: Int

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

  20. val ControlledShutdownRetryBackoffMs: Int

  21. val ControllerMessageQueueSize: Int

  22. val ControllerSocketTimeoutMs: Int

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

  23. val DefaultReplicationFactor: Int

  24. val Delete: String

  25. val DeleteTopicEnable: Boolean

  26. val FetchPurgatoryPurgeIntervalRequests: Int

  27. val HostName: String

  28. val InterBrokerProtocolVersion: String

  29. val InterBrokerSecurityProtocol: String

  30. val LeaderImbalanceCheckIntervalSeconds: Int

  31. val LeaderImbalancePerBrokerPercentage: Int

  32. val LogCleanerBackoffMs: Int

  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: Int

  44. val LogDir: String

  45. val LogFlushIntervalMessages: Long

  46. val LogFlushOffsetCheckpointIntervalMs: Int

  47. val LogFlushSchedulerIntervalMs: Long

  48. val LogIndexIntervalBytes: Int

  49. val LogIndexSizeMaxBytes: Int

  50. val LogPreAllocateEnable: Boolean

  51. val LogRetentionBytes: Long

  52. val LogRetentionHours: Int

  53. val LogRollHours: Int

  54. val LogRollJitterHours: Int

  55. val LogSegmentBytes: Int

  56. val MaxConnectionsPerIp: Int

  57. val MaxConnectionsPerIpOverrides: String

  58. val MaxReservedBrokerId: Int

  59. val MessageMaxBytes: Int

  60. val MetricNumSamples: Int

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

  61. val MetricReporterClasses: String

  62. val MetricSampleWindowMs: Int

  63. val MinInSyncReplicas: Int

  64. val NumIoThreads: Int

  65. val NumNetworkThreads: Int

  66. val NumPartitions: Int

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

  67. val NumQuotaSamples: Int

  68. val NumRecoveryThreadsPerDataDir: Int

  69. val NumReplicaFetchers: Int

  70. val OffsetCommitRequiredAcks: Short

  71. val OffsetCommitTimeoutMs: Int

  72. val OffsetMetadataMaxSize: Int

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

  73. val OffsetsLoadBufferSize: Int

  74. val OffsetsRetentionCheckIntervalMs: Long

  75. val OffsetsRetentionMinutes: Int

  76. val OffsetsTopicCompressionCodec: Int

  77. val OffsetsTopicPartitions: Int

  78. val OffsetsTopicReplicationFactor: Short

  79. val OffsetsTopicSegmentBytes: Int

  80. val Port: Int

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

  81. val PrincipalBuilderClass: String

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

  82. val ProducerPurgatoryPurgeIntervalRequests: Int

  83. val ProducerQuotaBytesPerSecondDefault: Long

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

  84. val QueuedMaxRequests: Int

  85. val QuotaWindowSizeSeconds: Int

  86. val ReplicaFetchBackoffMs: Int

  87. val ReplicaFetchMaxBytes: Int

  88. val ReplicaFetchMinBytes: Int

  89. val ReplicaFetchWaitMaxMs: Int

  90. val ReplicaHighWatermarkCheckpointIntervalMs: Long

  91. val ReplicaLagTimeMaxMs: Long

  92. val ReplicaSocketReceiveBufferBytes: Int

  93. val ReplicaSocketTimeoutMs: Int

  94. val RequestTimeoutMs: Int

  95. val SaslKerberosKinitCmd: String

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

  96. val SaslKerberosMinTimeBeforeRelogin: Long

  97. val SaslKerberosPrincipalToLocalRules: List[String]

  98. val SaslKerberosTicketRenewJitter: Double

  99. val SaslKerberosTicketRenewWindowFactor: Double

  100. val SocketReceiveBufferBytes: Int

  101. val SocketRequestMaxBytes: Int

  102. val SocketSendBufferBytes: Int

  103. val SslClientAuth: String

  104. val SslClientAuthNone: String

  105. val SslClientAuthRequested: String

  106. val SslClientAuthRequired: String

  107. val SslEnabledProtocols: String

  108. val SslKeyManagerAlgorithm: String

  109. val SslKeystoreType: String

  110. val SslProtocol: String

  111. val SslTrustManagerAlgorithm: String

  112. val SslTruststoreType: String

  113. val UncleanLeaderElectionEnable: Boolean

  114. val ZkEnableSecureAcls: Boolean

  115. val ZkSessionTimeoutMs: Int

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

  116. val ZkSyncTimeMs: Int

  117. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  118. def clone(): AnyRef

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

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

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

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

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

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

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

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

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

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

    Definition Classes
    AnyRef
  129. def toString(): String

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

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped