KafkaConfig

Instance Constructors

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

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 advertisedHostName: String
val advertisedListeners: Map[SecurityProtocol, EndPoint]
val advertisedPort: Integer
final def asInstanceOf[T0]: T0

Definition Classes
Any
val authorizerClassName: String

*********** Authorizer Configuration **********
val autoCreateTopicsEnable: Boolean

********* Log Configuration **********
val autoLeaderRebalanceEnable: Boolean
val backgroundThreads: Integer
var brokerId: Int
val brokerIdGenerationEnable: Boolean

********* General Configuration **********
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
val compressionType: String
val connectionsMaxIdleMs: Long
val consumerQuotaBytesPerSecondDefault: Long
val controlledShutdownEnable: Boolean
val controlledShutdownMaxRetries: Integer

********* Controlled shutdown configuration **********
val controlledShutdownRetryBackoffMs: Long
val controllerSocketTimeoutMs: Int

********* Replication configuration **********
val defaultReplicationFactor: Int
val deleteTopicEnable: Boolean
final def eq(arg0: AnyRef): Boolean

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

Definition Classes
AbstractConfig → AnyRef → Any
val fetchPurgatoryPurgeIntervalRequests: Integer
def finalize(): Unit

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

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

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

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

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

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

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

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

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

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

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

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

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

Definition Classes
AbstractConfig
val groupMaxSessionTimeoutMs: Integer
val groupMinSessionTimeoutMs: Integer

********* Group coordinator configuration **********
def hashCode(): Int

Definition Classes
AbstractConfig → AnyRef → Any
val hostName: String

********* Socket Server Configuration **********
def ignore(arg0: String): Unit

Definition Classes
AbstractConfig
val interBrokerProtocolVersion: ApiVersion
val interBrokerSecurityProtocol: SecurityProtocol
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
val leaderImbalanceCheckIntervalSeconds: Long
val leaderImbalancePerBrokerPercentage: Integer
val listeners: Map[SecurityProtocol, EndPoint]
val logCleanerBackoffMs: Long
val logCleanerDedupeBufferLoadFactor: Double
val logCleanerDedupeBufferSize: Long
val logCleanerDeleteRetentionMs: Long
val logCleanerEnable: Boolean
val logCleanerIoBufferSize: Integer
val logCleanerIoMaxBytesPerSecond: Double
val logCleanerMinCleanRatio: Double
val logCleanerThreads: Integer
val logCleanupIntervalMs: Long
val logCleanupPolicy: String
val logDeleteDelayMs: Long
val logDirs: Seq[String]
val logFlushIntervalMessages: Long
val logFlushIntervalMs: Long
val logFlushOffsetCheckpointIntervalMs: Long
val logFlushSchedulerIntervalMs: Long
val logIndexIntervalBytes: Integer
val logIndexSizeMaxBytes: Integer
val logPreAllocateEnable: Boolean
val logRetentionBytes: Long
val logRetentionTimeMillis: Long
val logRollTimeJitterMillis: Long
val logRollTimeMillis: Long
val logSegmentBytes: Integer
def logUnused(): Unit

Definition Classes
AbstractConfig
val maxConnectionsPerIp: Integer
val maxConnectionsPerIpOverrides: Map[String, Int]
val maxReservedBrokerId: Int
val messageMaxBytes: Integer
val metricNumSamples: Integer

********* Metric Configuration *************
val metricReporterClasses: List[MetricsReporter]
val metricSampleWindowMs: Long
val minInSyncReplicas: Integer
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
val numIoThreads: Integer
val numNetworkThreads: Integer
val numPartitions: Integer
val numQuotaSamples: Integer
val numRecoveryThreadsPerDataDir: Integer
val numReplicaFetchers: Integer
val offsetCommitRequiredAcks: Short
val offsetCommitTimeoutMs: Integer
val offsetMetadataMaxSize: Integer

********* Offset management configuration **********
val offsetsLoadBufferSize: Integer
val offsetsRetentionCheckIntervalMs: Long
val offsetsRetentionMinutes: Integer
val offsetsTopicCompressionCodec: CompressionCodec
val offsetsTopicPartitions: Integer
val offsetsTopicReplicationFactor: Short
val offsetsTopicSegmentBytes: Integer
def originals(): Map[String, AnyRef]

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

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

Definition Classes
AbstractConfig
val port: Integer
val principalBuilderClass: Class[_]

********* SSL Configuration *************
val producerPurgatoryPurgeIntervalRequests: Integer
val producerQuotaBytesPerSecondDefault: Long

********* Quota Configuration *************
val props: Map[_, _]
val queuedMaxRequests: Integer
val quotaWindowSizeSeconds: Integer
val replicaFetchBackoffMs: Integer
val replicaFetchMaxBytes: Integer
val replicaFetchMinBytes: Integer
val replicaFetchWaitMaxMs: Integer
val replicaHighWatermarkCheckpointIntervalMs: Long
val replicaLagTimeMaxMs: Long
val replicaSocketReceiveBufferBytes: Integer
val replicaSocketTimeoutMs: Integer
val requestTimeoutMs: Integer
val saslKerberosKinitCmd: String
val saslKerberosMinTimeBeforeRelogin: Long
val saslKerberosPrincipalToLocalRules: List[String]
val saslKerberosServiceName: String

********* Sasl Configuration *************
val saslKerberosTicketRenewJitter: Double
val saslKerberosTicketRenewWindowFactor: Double
val socketReceiveBufferBytes: Integer
val socketRequestMaxBytes: Integer
val socketSendBufferBytes: Integer
val sslCipher: List[String]
val sslClientAuth: String
val sslEnabledProtocols: List[String]
val sslKeyManagerAlgorithm: String
val sslKeyPassword: Password
val sslKeystoreLocation: String
val sslKeystorePassword: Password
val sslKeystoreType: String
val sslProtocol: String
val sslProvider: String
val sslTrustManagerAlgorithm: String
val sslTruststoreLocation: String
val sslTruststorePassword: Password
val sslTruststoreType: String
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
val uncleanLeaderElectionEnable: Boolean
def unused(): Set[String]

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

Definition Classes
AbstractConfig
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( ... )
val zkConnect: String

********* Zookeeper Configuration **********
val zkConnectionTimeoutMs: Int
val zkEnableSecureAcls: Boolean
val zkSessionTimeoutMs: Int
val zkSyncTimeMs: Int

Related Docs: object KafkaConfig | package server

class KafkaConfig extends AbstractConfig

Instance Constructors

new KafkaConfig(props: Map[_, _])

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

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

val advertisedHostName: String

val advertisedListeners: Map[SecurityProtocol, EndPoint]

val advertisedPort: Integer

final def asInstanceOf[T0]: T0

val authorizerClassName: String

val autoCreateTopicsEnable: Boolean

val autoLeaderRebalanceEnable: Boolean

val backgroundThreads: Integer

var brokerId: Int

val brokerIdGenerationEnable: Boolean

def clone(): AnyRef

val compressionType: String

val connectionsMaxIdleMs: Long

val consumerQuotaBytesPerSecondDefault: Long

val controlledShutdownEnable: Boolean

val controlledShutdownMaxRetries: Integer

val controlledShutdownRetryBackoffMs: Long

val controllerSocketTimeoutMs: Int

val defaultReplicationFactor: Int

val deleteTopicEnable: Boolean

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

val fetchPurgatoryPurgeIntervalRequests: Integer

def finalize(): Unit

def get(arg0: String): AnyRef

def getBoolean(arg0: String): Boolean

def getClass(arg0: String): Class[_]

final def getClass(): Class[_]

def getConfiguredInstance[T](arg0: String, arg1: Class[T]): T

def getConfiguredInstances[T](arg0: String, arg1: Class[T]): List[T]

def getDouble(arg0: String): Double

def getInt(arg0: String): Integer

def getList(arg0: String): List[String]

def getLong(arg0: String): Long

def getPassword(arg0: String): Password

def getShort(arg0: String): Short

def getString(arg0: String): String

val groupMaxSessionTimeoutMs: Integer

val groupMinSessionTimeoutMs: Integer

def hashCode(): Int

val hostName: String

def ignore(arg0: String): Unit

val interBrokerProtocolVersion: ApiVersion

val interBrokerSecurityProtocol: SecurityProtocol

final def isInstanceOf[T0]: Boolean

val leaderImbalanceCheckIntervalSeconds: Long

val leaderImbalancePerBrokerPercentage: Integer

val listeners: Map[SecurityProtocol, EndPoint]

val logCleanerBackoffMs: Long

val logCleanerDedupeBufferLoadFactor: Double

val logCleanerDedupeBufferSize: Long

val logCleanerDeleteRetentionMs: Long

val logCleanerEnable: Boolean

val logCleanerIoBufferSize: Integer

val logCleanerIoMaxBytesPerSecond: Double

val logCleanerMinCleanRatio: Double

val logCleanerThreads: Integer

val logCleanupIntervalMs: Long

val logCleanupPolicy: String

val logDeleteDelayMs: Long

val logDirs: Seq[String]

val logFlushIntervalMessages: Long

val logFlushIntervalMs: Long

val logFlushOffsetCheckpointIntervalMs: Long

val logFlushSchedulerIntervalMs: Long

val logIndexIntervalBytes: Integer

val logIndexSizeMaxBytes: Integer

val logPreAllocateEnable: Boolean

val logRetentionBytes: Long

val logRetentionTimeMillis: Long