Defaults

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

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

Definition Classes
AnyRef → Any
val AuthorizerClassName: String

*********** Authorizer Configuration **********
val AutoCreateTopicsEnable: Boolean
val AutoLeaderRebalanceEnable: Boolean
val BackgroundThreads: Int
val BrokerId: Int
val BrokerIdGenerationEnable: Boolean

********* General Configuration **********
val Compact: String
val CompressionType: String
val ConnectionsMaxIdleMs: Long
val ConsumerMaxSessionTimeoutMs: Int
val ConsumerMinSessionTimeoutMs: Int

********* Consumer coordinator configuration **********
val ConsumerQuotaBytesPerSecondDefault: Long
val ControlledShutdownEnable: Boolean
val ControlledShutdownMaxRetries: Int

********* Controlled shutdown configuration **********
val ControlledShutdownRetryBackoffMs: Int
val ControllerMessageQueueSize: Int
val ControllerSocketTimeoutMs: Int

********* Replication configuration **********
val DefaultReplicationFactor: Int
val Delete: String
val DeleteTopicEnable: Boolean
val FetchPurgatoryPurgeIntervalRequests: Int
val HostName: String
val InterBrokerProtocolVersion: String
val InterBrokerSecurityProtocol: String
val LeaderImbalanceCheckIntervalSeconds: Int
val LeaderImbalancePerBrokerPercentage: Int
val LogCleanerBackoffMs: Int
val LogCleanerDedupeBufferLoadFactor: Double
val LogCleanerDedupeBufferSize: Long
val LogCleanerDeleteRetentionMs: Long
val LogCleanerEnable: Boolean
val LogCleanerIoBufferSize: Int
val LogCleanerIoMaxBytesPerSecond: Double
val LogCleanerMinCleanRatio: Double
val LogCleanerThreads: Int
val LogCleanupIntervalMs: Long
val LogCleanupPolicy: String
val LogDeleteDelayMs: Int
val LogDir: String
val LogFlushIntervalMessages: Long
val LogFlushOffsetCheckpointIntervalMs: Int
val LogFlushSchedulerIntervalMs: Long
val LogIndexIntervalBytes: Int
val LogIndexSizeMaxBytes: Int
val LogPreAllocateEnable: Boolean
val LogRetentionBytes: Long
val LogRetentionHours: Int
val LogRollHours: Int
val LogRollJitterHours: Int
val LogSegmentBytes: Int
val MaxConnectionsPerIp: Int
val MaxConnectionsPerIpOverrides: String
val MaxReservedBrokerId: Int
val MessageMaxBytes: Int
val MetricNumSamples: Int

********* Kafka Metrics Configuration **********
val MetricReporterClasses: String
val MetricSampleWindowMs: Int
val MinInSyncReplicas: Int
val NumIoThreads: Int
val NumNetworkThreads: Int
val NumPartitions: Int

********* Log Configuration **********
val NumQuotaSamples: Int
val NumRecoveryThreadsPerDataDir: Int
val NumReplicaFetchers: Int
val OffsetCommitRequiredAcks: Short
val OffsetCommitTimeoutMs: Int
val OffsetMetadataMaxSize: Int

********* Offset management configuration **********
val OffsetsLoadBufferSize: Int
val OffsetsRetentionCheckIntervalMs: Long
val OffsetsRetentionMinutes: Int
val OffsetsTopicCompressionCodec: Int
val OffsetsTopicPartitions: Int
val OffsetsTopicReplicationFactor: Short
val OffsetsTopicSegmentBytes: Int
val Port: Int

********* Socket Server Configuration **********
val PrincipalBuilderClass: String

********* SSL configuration **********
val ProducerPurgatoryPurgeIntervalRequests: Int
val ProducerQuotaBytesPerSecondDefault: Long

********* Quota Configuration **********
val QueuedMaxRequests: Int
val QuotaWindowSizeSeconds: Int
val ReplicaFetchBackoffMs: Int
val ReplicaFetchMaxBytes: Int
val ReplicaFetchMinBytes: Int
val ReplicaFetchWaitMaxMs: Int
val ReplicaHighWatermarkCheckpointIntervalMs: Long
val ReplicaLagTimeMaxMs: Long
val ReplicaSocketReceiveBufferBytes: Int
val ReplicaSocketTimeoutMs: Int
val RequestTimeoutMs: Int
val SaslKerberosKinitCmd: String

********* Sasl configuration **********
val SaslKerberosMinTimeBeforeRelogin: Long
val SaslKerberosPrincipalToLocalRules: List[String]
val SaslKerberosTicketRenewJitter: Double
val SaslKerberosTicketRenewWindowFactor: Double
val SocketReceiveBufferBytes: Int
val SocketRequestMaxBytes: Int
val SocketSendBufferBytes: Int
val SslClientAuth: String
val SslClientAuthNone: String
val SslClientAuthRequested: String
val SslClientAuthRequired: String
val SslEnabledProtocols: String
val SslKeyManagerAlgorithm: String
val SslKeystoreType: String
val SslProtocol: String
val SslTrustManagerAlgorithm: String
val SslTruststoreType: String
val UncleanLeaderElectionEnable: Boolean
val ZkEnableSecureAcls: Boolean
val ZkSessionTimeoutMs: Int

********* Zookeeper Configuration **********
val ZkSyncTimeMs: Int
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

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

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

Definition Classes
AnyRef → Any
def finalize(): Unit

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

Definition Classes
AnyRef → Any
def hashCode(): Int

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

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

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

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

Definition Classes
AnyRef
def toString(): String

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

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

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

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Doc: package server

object Defaults

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

val AuthorizerClassName: String

val AutoCreateTopicsEnable: Boolean

val AutoLeaderRebalanceEnable: Boolean

val BackgroundThreads: Int

val BrokerId: Int

val BrokerIdGenerationEnable: Boolean

val Compact: String

val CompressionType: String

val ConnectionsMaxIdleMs: Long

val ConsumerMaxSessionTimeoutMs: Int

val ConsumerMinSessionTimeoutMs: Int

val ConsumerQuotaBytesPerSecondDefault: Long

val ControlledShutdownEnable: Boolean

val ControlledShutdownMaxRetries: Int

val ControlledShutdownRetryBackoffMs: Int

val ControllerMessageQueueSize: Int

val ControllerSocketTimeoutMs: Int

val DefaultReplicationFactor: Int

val Delete: String

val DeleteTopicEnable: Boolean

val FetchPurgatoryPurgeIntervalRequests: Int

val HostName: String

val InterBrokerProtocolVersion: String

val InterBrokerSecurityProtocol: String

val LeaderImbalanceCheckIntervalSeconds: Int

val LeaderImbalancePerBrokerPercentage: Int

val LogCleanerBackoffMs: Int

val LogCleanerDedupeBufferLoadFactor: Double

val LogCleanerDedupeBufferSize: Long

val LogCleanerDeleteRetentionMs: Long

val LogCleanerEnable: Boolean

val LogCleanerIoBufferSize: Int

val LogCleanerIoMaxBytesPerSecond: Double

val LogCleanerMinCleanRatio: Double

val LogCleanerThreads: Int

val LogCleanupIntervalMs: Long

val LogCleanupPolicy: String

val LogDeleteDelayMs: Int

val LogDir: String

val LogFlushIntervalMessages: Long

val LogFlushOffsetCheckpointIntervalMs: Int

val LogFlushSchedulerIntervalMs: Long

val LogIndexIntervalBytes: Int

val LogIndexSizeMaxBytes: Int

val LogPreAllocateEnable: Boolean

val LogRetentionBytes: Long

val LogRetentionHours: Int

val LogRollHours: Int

val LogRollJitterHours: Int

val LogSegmentBytes: Int

val MaxConnectionsPerIp: Int

val MaxConnectionsPerIpOverrides: String

val MaxReservedBrokerId: Int

val MessageMaxBytes: Int

val MetricNumSamples: Int

val MetricReporterClasses: String

val MetricSampleWindowMs: Int

val MinInSyncReplicas: Int

val NumIoThreads: Int

val NumNetworkThreads: Int

val NumPartitions: Int

val NumQuotaSamples: Int

val NumRecoveryThreadsPerDataDir: Int

val NumReplicaFetchers: Int

val OffsetCommitRequiredAcks: Short

val OffsetCommitTimeoutMs: Int

val OffsetMetadataMaxSize: Int

val OffsetsLoadBufferSize: Int

val OffsetsRetentionCheckIntervalMs: Long

val OffsetsRetentionMinutes: Int

val OffsetsTopicCompressionCodec: Int

val OffsetsTopicPartitions: Int

val OffsetsTopicReplicationFactor: Short