KafkaConfig

Instance Constructors

new KafkaConfig(originalProps: Properties)

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 advertisedPort: Int
final def asInstanceOf[T0]: T0

Definition Classes
Any
val autoCreateTopicsEnable: Boolean
val autoLeaderRebalanceEnable: Boolean
val backgroundThreads: Int
val brokerId: Int

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

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

Controlled shutdown can fail for multiple reasons.
Controlled shutdown can fail for multiple reasons. This determines the number of retries when such failure happens
val controlledShutdownRetryBackoffMs: Int

Before each retry, the system needs time to recover from the state that caused the previous failure (Controller fail over, replica lag etc).
Before each retry, the system needs time to recover from the state that caused the previous failure (Controller fail over, replica lag etc). This config determines the amount of time to wait before retrying.
val controllerMessageQueueSize: Int
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
AnyRef → Any
val fetchPurgatoryPurgeIntervalRequests: Int
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
val hostName: String
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
val leaderImbalanceCheckIntervalSeconds: Int
val leaderImbalancePerBrokerPercentage: Int
val logCleanerBackoffMs: Long
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: Long
val logDirs: Seq[String]
val logFlushIntervalMessages: Long
val logFlushIntervalMs: Long
val logFlushOffsetCheckpointIntervalMs: Int
val logFlushSchedulerIntervalMs: Long
val logIndexIntervalBytes: Int
val logIndexSizeMaxBytes: Int
val logRetentionBytes: Long
val logRetentionTimeMillis: Long
val logRollTimeJitterMillis: Long
val logRollTimeMillis: Long
val logSegmentBytes: Int
val maxConnectionsPerIp: Int
val maxConnectionsPerIpOverrides: Map[String, Int]
val messageMaxBytes: Int
val minInSyncReplicas: Int
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: Int
val numNetworkThreads: Int
val numPartitions: Int

********* Log Configuration **********
val numRecoveryThreadsPerDataDir: Int
val numReplicaFetchers: Int
val offsetCommitRequiredAcks: Short

The required acks before the commit can be accepted.
The required acks before the commit can be accepted. In general, the default (-1) should not be overridden.
val offsetCommitTimeoutMs: Int
val offsetMetadataMaxSize: Int

********* Offset management configuration **********
val offsetsLoadBufferSize: Int

Batch size for reading from the offsets segments when loading offsets into the cache.
val offsetsRetentionCheckIntervalMs: Long

Frequency at which to check for stale offsets.
val offsetsRetentionMinutes: Int

Offsets older than this retention period will be discarded.
val offsetsTopicCompressionCodec: CompressionCodec

Compression codec for the offsets topic - compression may be used to achieve "atomic" commits.
val offsetsTopicPartitions: Int

The number of partitions for the offset commit topic (should not change after deployment).
val offsetsTopicReplicationFactor: Short

The replication factor for the offset commit topic (set higher to ensure availability).
val offsetsTopicSegmentBytes: Int

The offsets topic segment bytes should be kept relatively small in order to facilitate faster log compaction and cache loads
val port: Int

********* Socket Server Configuration **********
val producerPurgatoryPurgeIntervalRequests: Int
val props: VerifiableProperties
val queuedMaxRequests: Int
val replicaFetchMaxBytes: Int
val replicaFetchMinBytes: Int
val replicaFetchWaitMaxMs: Int
val replicaHighWatermarkCheckpointIntervalMs: Long
val replicaLagMaxMessages: Long
val replicaLagTimeMaxMs: Long
val replicaSocketReceiveBufferBytes: Int
val replicaSocketTimeoutMs: Int
val socketReceiveBufferBytes: Int
val socketRequestMaxBytes: Int
val socketSendBufferBytes: Int
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
val uncleanLeaderElectionEnable: Boolean
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

ZK host string
ZK host string

Definition Classes
ZKConfig
val zkConnectionTimeoutMs: Int

the max time that the client waits to establish a connection to zookeeper
the max time that the client waits to establish a connection to zookeeper

Definition Classes
ZKConfig
val zkSessionTimeoutMs: Int

zookeeper session timeout
zookeeper session timeout

Definition Classes
ZKConfig
val zkSyncTimeMs: Int

how far a ZK follower can be behind a ZK leader
how far a ZK follower can be behind a ZK leader

Definition Classes
ZKConfig

class KafkaConfig extends ZKConfig

Instance Constructors

new KafkaConfig(originalProps: Properties)

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

val advertisedHostName: String

val advertisedPort: Int

final def asInstanceOf[T0]: T0

val autoCreateTopicsEnable: Boolean

val autoLeaderRebalanceEnable: Boolean

val backgroundThreads: Int

val brokerId: Int

def clone(): AnyRef

val connectionsMaxIdleMs: Long

val controlledShutdownEnable: Boolean

val controlledShutdownMaxRetries: Int

val controlledShutdownRetryBackoffMs: Int

val controllerMessageQueueSize: Int

val controllerSocketTimeoutMs: Int

val defaultReplicationFactor: Int

val deleteTopicEnable: Boolean

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

val fetchPurgatoryPurgeIntervalRequests: Int

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

val hostName: String

final def isInstanceOf[T0]: Boolean

val leaderImbalanceCheckIntervalSeconds: Int

val leaderImbalancePerBrokerPercentage: Int

val logCleanerBackoffMs: Long

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

val logDirs: Seq[String]

val logFlushIntervalMessages: Long

val logFlushIntervalMs: Long

val logFlushOffsetCheckpointIntervalMs: Int

val logFlushSchedulerIntervalMs: Long

val logIndexIntervalBytes: Int

val logIndexSizeMaxBytes: Int

val logRetentionBytes: Long

val logRetentionTimeMillis: Long

val logRollTimeJitterMillis: Long

val logRollTimeMillis: Long

val logSegmentBytes: Int

val maxConnectionsPerIp: Int

val maxConnectionsPerIpOverrides: Map[String, Int]

val messageMaxBytes: Int

val minInSyncReplicas: Int

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

val numIoThreads: Int

val numNetworkThreads: Int

val numPartitions: 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: CompressionCodec

val offsetsTopicPartitions: Int

val offsetsTopicReplicationFactor: Short

val offsetsTopicSegmentBytes: Int