KafkaConfig

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 AdvertisedHostNameDoc: String
val AdvertisedHostNameProp: String
val AdvertisedListenersDoc: String
val AdvertisedListenersProp: String
val AdvertisedPortDoc: String
val AdvertisedPortProp: String
val AuthorizerClassNameDoc: String

*********** Authorizer Configuration **********
val AuthorizerClassNameProp: String

*********** Authorizer Configuration **********
val AutoCreateTopicsEnableDoc: String
val AutoCreateTopicsEnableProp: String
val AutoLeaderRebalanceEnableDoc: String
val AutoLeaderRebalanceEnableProp: String
val BackgroundThreadsDoc: String
val BackgroundThreadsProp: String
val BrokerIdDoc: String
val BrokerIdGenerationEnableDoc: String

********* General Configuration **********
val BrokerIdGenerationEnableProp: String

********* General Configuration **********
val BrokerIdProp: String
val CompressionTypeDoc: String
val CompressionTypeProp: String
val ConnectionsMaxIdleMsDoc: String
val ConnectionsMaxIdleMsProp: String
val ConsumerMaxSessionTimeoutMsDoc: String
val ConsumerMinSessionTimeoutMsDoc: String

********* Consumer coordinator configuration **********
val ConsumerQuotaBytesPerSecondDefaultDoc: String
val ConsumerQuotaBytesPerSecondDefaultProp: String
val ControlledShutdownEnableDoc: String
val ControlledShutdownEnableProp: String
val ControlledShutdownMaxRetriesDoc: String

********* Controlled shutdown configuration **********
val ControlledShutdownMaxRetriesProp: String

********* Controlled shutdown configuration **********
val ControlledShutdownRetryBackoffMsDoc: String
val ControlledShutdownRetryBackoffMsProp: String
val ControllerMessageQueueSizeDoc: String
val ControllerSocketTimeoutMsDoc: String

********* Replication configuration **********
val ControllerSocketTimeoutMsProp: String

********* Replication configuration **********
val DefaultReplicationFactorDoc: String
val DefaultReplicationFactorProp: String
val DeleteTopicEnableDoc: String
val DeleteTopicEnableProp: String
val FetchPurgatoryPurgeIntervalRequestsDoc: String
val FetchPurgatoryPurgeIntervalRequestsProp: String
val GroupMaxSessionTimeoutMsProp: String
val GroupMinSessionTimeoutMsProp: String

********* Group coordinator configuration **********
val HostNameDoc: String
val HostNameProp: String
val InterBrokerProtocolVersionDoc: String
val InterBrokerProtocolVersionProp: String
val InterBrokerSecurityProtocolDoc: String
val InterBrokerSecurityProtocolProp: String
val LeaderImbalanceCheckIntervalSecondsDoc: String
val LeaderImbalanceCheckIntervalSecondsProp: String
val LeaderImbalancePerBrokerPercentageDoc: String
val LeaderImbalancePerBrokerPercentageProp: String
val ListenersDoc: String
val ListenersProp: String
val LogCleanerBackoffMsDoc: String
val LogCleanerBackoffMsProp: String
val LogCleanerDedupeBufferLoadFactorDoc: String
val LogCleanerDedupeBufferLoadFactorProp: String
val LogCleanerDedupeBufferSizeDoc: String
val LogCleanerDedupeBufferSizeProp: String
val LogCleanerDeleteRetentionMsDoc: String
val LogCleanerDeleteRetentionMsProp: String
val LogCleanerEnableDoc: String
val LogCleanerEnableProp: String
val LogCleanerIoBufferSizeDoc: String
val LogCleanerIoBufferSizeProp: String
val LogCleanerIoMaxBytesPerSecondDoc: String
val LogCleanerIoMaxBytesPerSecondProp: String
val LogCleanerMinCleanRatioDoc: String
val LogCleanerMinCleanRatioProp: String
val LogCleanerThreadsDoc: String
val LogCleanerThreadsProp: String
val LogCleanupIntervalMsDoc: String
val LogCleanupIntervalMsProp: String
val LogCleanupPolicyDoc: String
val LogCleanupPolicyProp: String
val LogDeleteDelayMsDoc: String
val LogDeleteDelayMsProp: String
val LogDirDoc: String
val LogDirProp: String
val LogDirsDoc: String
val LogDirsProp: String
val LogFlushIntervalMessagesDoc: String
val LogFlushIntervalMessagesProp: String
val LogFlushIntervalMsDoc: String
val LogFlushIntervalMsProp: String
val LogFlushOffsetCheckpointIntervalMsDoc: String
val LogFlushOffsetCheckpointIntervalMsProp: String
val LogFlushSchedulerIntervalMsDoc: String
val LogFlushSchedulerIntervalMsProp: String
val LogIndexIntervalBytesDoc: String
val LogIndexIntervalBytesProp: String
val LogIndexSizeMaxBytesDoc: String
val LogIndexSizeMaxBytesProp: String
val LogPreAllocateEnableDoc: String
val LogPreAllocateProp: String
val LogRetentionBytesDoc: String
val LogRetentionBytesProp: String
val LogRetentionTimeHoursDoc: String
val LogRetentionTimeHoursProp: String
val LogRetentionTimeMillisDoc: String
val LogRetentionTimeMillisProp: String
val LogRetentionTimeMinsDoc: String
val LogRetentionTimeMinutesProp: String
val LogRollTimeHoursDoc: String
val LogRollTimeHoursProp: String
val LogRollTimeJitterHoursDoc: String
val LogRollTimeJitterHoursProp: String
val LogRollTimeJitterMillisDoc: String
val LogRollTimeJitterMillisProp: String
val LogRollTimeMillisDoc: String
val LogRollTimeMillisProp: String
val LogSegmentBytesDoc: String
val LogSegmentBytesProp: String
val MaxConnectionsPerIpDoc: String
val MaxConnectionsPerIpOverridesDoc: String
val MaxConnectionsPerIpOverridesProp: String
val MaxConnectionsPerIpProp: String
val MaxReservedBrokerIdDoc: String
val MaxReservedBrokerIdProp: String
val MessageMaxBytesDoc: String
val MessageMaxBytesProp: String
val MetricNumSamplesDoc: String
val MetricNumSamplesProp: String
val MetricReporterClassesDoc: String
val MetricReporterClassesProp: String
val MetricSampleWindowMsDoc: String

********* Kafka Metrics Configuration **********
val MetricSampleWindowMsProp: String

********* Kafka Metrics Configuration **********
val MinInSyncReplicasDoc: String
val MinInSyncReplicasProp: String
val NumIoThreadsDoc: String
val NumIoThreadsProp: String
val NumNetworkThreadsDoc: String
val NumNetworkThreadsProp: String
val NumPartitionsDoc: String

********* Log Configuration **********
val NumPartitionsProp: String

********* Log Configuration **********
val NumQuotaSamplesDoc: String
val NumQuotaSamplesProp: String
val NumRecoveryThreadsPerDataDirDoc: String
val NumRecoveryThreadsPerDataDirProp: String
val NumReplicaFetchersDoc: String
val NumReplicaFetchersProp: String
val OffsetCommitRequiredAcksDoc: String
val OffsetCommitRequiredAcksProp: String
val OffsetCommitTimeoutMsDoc: String
val OffsetCommitTimeoutMsProp: String
val OffsetMetadataMaxSizeDoc: String

********* Offset management configuration **********
val OffsetMetadataMaxSizeProp: String

********* Offset management configuration **********
val OffsetsLoadBufferSizeDoc: String
val OffsetsLoadBufferSizeProp: String
val OffsetsRetentionCheckIntervalMsDoc: String
val OffsetsRetentionCheckIntervalMsProp: String
val OffsetsRetentionMinutesDoc: String
val OffsetsRetentionMinutesProp: String
val OffsetsTopicCompressionCodecDoc: String
val OffsetsTopicCompressionCodecProp: String
val OffsetsTopicPartitionsDoc: String
val OffsetsTopicPartitionsProp: String
val OffsetsTopicReplicationFactorDoc: String
val OffsetsTopicReplicationFactorProp: String
val OffsetsTopicSegmentBytesDoc: String
val OffsetsTopicSegmentBytesProp: String
val PortDoc: String

********* Socket Server Configuration **********
val PortProp: String

********* Socket Server Configuration **********
val PrincipalBuilderClassDoc: String

********* SSL Configuration ***************
val PrincipalBuilderClassProp: String

********* SSL Configuration ***************
val ProducerPurgatoryPurgeIntervalRequestsDoc: String
val ProducerPurgatoryPurgeIntervalRequestsProp: String
val ProducerQuotaBytesPerSecondDefaultDoc: String

********* Quota Configuration **********
val ProducerQuotaBytesPerSecondDefaultProp: String

********* Quota Configuration **********
val QueuedMaxRequestsDoc: String
val QueuedMaxRequestsProp: String
val QuotaWindowSizeSecondsDoc: String
val QuotaWindowSizeSecondsProp: String
val ReplicaFetchBackoffMsDoc: String
val ReplicaFetchBackoffMsProp: String
val ReplicaFetchMaxBytesDoc: String
val ReplicaFetchMaxBytesProp: String
val ReplicaFetchMinBytesDoc: String
val ReplicaFetchMinBytesProp: String
val ReplicaFetchWaitMaxMsDoc: String
val ReplicaFetchWaitMaxMsProp: String
val ReplicaHighWatermarkCheckpointIntervalMsDoc: String
val ReplicaHighWatermarkCheckpointIntervalMsProp: String
val ReplicaLagTimeMaxMsDoc: String
val ReplicaLagTimeMaxMsProp: String
val ReplicaSocketReceiveBufferBytesDoc: String
val ReplicaSocketReceiveBufferBytesProp: String
val ReplicaSocketTimeoutMsDoc: String
val ReplicaSocketTimeoutMsProp: String
val RequestTimeoutMsDoc: String
val RequestTimeoutMsProp: String
val SaslKerberosKinitCmdDoc: String
val SaslKerberosKinitCmdProp: String
val SaslKerberosMinTimeBeforeReloginDoc: String
val SaslKerberosMinTimeBeforeReloginProp: String
val SaslKerberosPrincipalToLocalRulesDoc: String
val SaslKerberosPrincipalToLocalRulesProp: String
val SaslKerberosServiceNameDoc: String

********* Sasl Configuration ***************
val SaslKerberosServiceNameProp: String

********* SASL Configuration ***************
val SaslKerberosTicketRenewJitterDoc: String
val SaslKerberosTicketRenewJitterProp: String
val SaslKerberosTicketRenewWindowFactorDoc: String
val SaslKerberosTicketRenewWindowFactorProp: String
val SocketReceiveBufferBytesDoc: String
val SocketReceiveBufferBytesProp: String
val SocketRequestMaxBytesDoc: String
val SocketRequestMaxBytesProp: String
val SocketSendBufferBytesDoc: String
val SocketSendBufferBytesProp: String
val SslCipherSuitesDoc: String
val SslCipherSuitesProp: String
val SslClientAuthDoc: String
val SslClientAuthProp: String
val SslEnabledProtocolsDoc: String
val SslEnabledProtocolsProp: String
val SslEndpointIdentificationAlgorithmDoc: String
val SslEndpointIdentificationAlgorithmProp: String
val SslKeyManagerAlgorithmDoc: String
val SslKeyManagerAlgorithmProp: String
val SslKeyPasswordDoc: String
val SslKeyPasswordProp: String
val SslKeystoreLocationDoc: String
val SslKeystoreLocationProp: String
val SslKeystorePasswordDoc: String
val SslKeystorePasswordProp: String
val SslKeystoreTypeDoc: String
val SslKeystoreTypeProp: String
val SslProtocolDoc: String
val SslProtocolProp: String
val SslProviderDoc: String
val SslProviderProp: String
val SslTrustManagerAlgorithmDoc: String
val SslTrustManagerAlgorithmProp: String
val SslTruststoreLocationDoc: String
val SslTruststoreLocationProp: String
val SslTruststorePasswordDoc: String
val SslTruststorePasswordProp: String
val SslTruststoreTypeDoc: String
val SslTruststoreTypeProp: String
val UncleanLeaderElectionEnableDoc: String
val UncleanLeaderElectionEnableProp: String
val ZkConnectDoc: String

********* Zookeeper Configuration **********
val ZkConnectProp: String

********* Zookeeper Configuration **********
val ZkConnectionTimeoutMsDoc: String
val ZkConnectionTimeoutMsProp: String
val ZkEnableSecureAclsDoc: String
val ZkEnableSecureAclsProp: String
val ZkSessionTimeoutMsDoc: String
val ZkSessionTimeoutMsProp: String
val ZkSyncTimeMsDoc: String
val ZkSyncTimeMsProp: String
def apply(props: Map[_, _]): KafkaConfig
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def configNames(): List[String]
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] )
def fromProps(defaults: Properties, overrides: Properties, doLog: Boolean): KafkaConfig
def fromProps(defaults: Properties, overrides: Properties): KafkaConfig
def fromProps(props: Properties, doLog: Boolean): KafkaConfig
def fromProps(props: Properties): KafkaConfig
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

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

Definition Classes
Any
def main(args: Array[String]): Unit
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
def validateNames(props: Properties): Unit

Check that property names are valid
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 Docs: class KafkaConfig | package server

object KafkaConfig

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

val AdvertisedHostNameDoc: String

val AdvertisedHostNameProp: String

val AdvertisedListenersDoc: String

val AdvertisedListenersProp: String

val AdvertisedPortDoc: String

val AdvertisedPortProp: String

val AuthorizerClassNameDoc: String

val AuthorizerClassNameProp: String

val AutoCreateTopicsEnableDoc: String

val AutoCreateTopicsEnableProp: String

val AutoLeaderRebalanceEnableDoc: String

val AutoLeaderRebalanceEnableProp: String

val BackgroundThreadsDoc: String

val BackgroundThreadsProp: String

val BrokerIdDoc: String

val BrokerIdGenerationEnableDoc: String

val BrokerIdGenerationEnableProp: String

val BrokerIdProp: String

val CompressionTypeDoc: String

val CompressionTypeProp: String

val ConnectionsMaxIdleMsDoc: String

val ConnectionsMaxIdleMsProp: String

val ConsumerMaxSessionTimeoutMsDoc: String

val ConsumerMinSessionTimeoutMsDoc: String

val ConsumerQuotaBytesPerSecondDefaultDoc: String

val ConsumerQuotaBytesPerSecondDefaultProp: String

val ControlledShutdownEnableDoc: String

val ControlledShutdownEnableProp: String

val ControlledShutdownMaxRetriesDoc: String

val ControlledShutdownMaxRetriesProp: String

val ControlledShutdownRetryBackoffMsDoc: String

val ControlledShutdownRetryBackoffMsProp: String

val ControllerMessageQueueSizeDoc: String

val ControllerSocketTimeoutMsDoc: String

val ControllerSocketTimeoutMsProp: String

val DefaultReplicationFactorDoc: String

val DefaultReplicationFactorProp: String

val DeleteTopicEnableDoc: String

val DeleteTopicEnableProp: String

val FetchPurgatoryPurgeIntervalRequestsDoc: String

val FetchPurgatoryPurgeIntervalRequestsProp: String

val GroupMaxSessionTimeoutMsProp: String

val GroupMinSessionTimeoutMsProp: String

val HostNameDoc: String

val HostNameProp: String

val InterBrokerProtocolVersionDoc: String

val InterBrokerProtocolVersionProp: String

val InterBrokerSecurityProtocolDoc: String

val InterBrokerSecurityProtocolProp: String

val LeaderImbalanceCheckIntervalSecondsDoc: String

val LeaderImbalanceCheckIntervalSecondsProp: String

val LeaderImbalancePerBrokerPercentageDoc: String

val LeaderImbalancePerBrokerPercentageProp: String

val ListenersDoc: String

val ListenersProp: String

val LogCleanerBackoffMsDoc: String

val LogCleanerBackoffMsProp: String

val LogCleanerDedupeBufferLoadFactorDoc: String

val LogCleanerDedupeBufferLoadFactorProp: String

val LogCleanerDedupeBufferSizeDoc: String

val LogCleanerDedupeBufferSizeProp: String

val LogCleanerDeleteRetentionMsDoc: String

val LogCleanerDeleteRetentionMsProp: String

val LogCleanerEnableDoc: String

val LogCleanerEnableProp: String

val LogCleanerIoBufferSizeDoc: String

val LogCleanerIoBufferSizeProp: String

val LogCleanerIoMaxBytesPerSecondDoc: String

val LogCleanerIoMaxBytesPerSecondProp: String

val LogCleanerMinCleanRatioDoc: String

val LogCleanerMinCleanRatioProp: String

val LogCleanerThreadsDoc: String

val LogCleanerThreadsProp: String