kafka.server

KafkaConfig

case class KafkaConfig(props: Map[_, _]) extends AbstractConfig with Product with Serializable

Linear Supertypes
Serializable, Serializable, Product, Equals, AbstractConfig, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. KafkaConfig
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. AbstractConfig
  7. AnyRef
  8. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

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

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 advertisedHostName: String

  7. val advertisedListeners: Map[SecurityProtocol, EndPoint]

  8. val advertisedPort: Integer

  9. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  10. val authorizerClassName: String

    *********** Authorizer Configuration **********

  11. val autoCreateTopicsEnable: Boolean

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

  12. val autoLeaderRebalanceEnable: Boolean

  13. val backgroundThreads: Integer

  14. var brokerId: Int

  15. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  16. val compressionType: String

  17. val connectionsMaxIdleMs: Long

  18. val consumerQuotaBytesPerSecondDefault: Long

  19. val controlledShutdownEnable: Boolean

  20. val controlledShutdownMaxRetries: Integer

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

  21. val controlledShutdownRetryBackoffMs: Long

  22. val controllerSocketTimeoutMs: Int

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

  23. val defaultReplicationFactor: Int

  24. val deleteTopicEnable: Boolean

  25. final def eq(arg0: AnyRef): Boolean

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

    Definition Classes
    AbstractConfig → AnyRef → Any
  27. val fetchPurgatoryPurgeIntervalRequests: Integer

  28. def finalize(): Unit

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

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

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

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

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

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

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

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

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

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

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

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

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

    Definition Classes
    AbstractConfig
  42. val groupMaxSessionTimeoutMs: Integer

  43. val groupMinSessionTimeoutMs: Integer

    ********* Group coordinator configuration **********

  44. def hashCode(): Int

    Definition Classes
    AbstractConfig → AnyRef → Any
  45. val hostName: String

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

  46. def ignore(arg0: String): Unit

    Definition Classes
    AbstractConfig
  47. val interBrokerProtocolVersion: ApiVersion

  48. val interBrokerSecurityProtocol: SecurityProtocol

  49. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  50. val leaderImbalanceCheckIntervalSeconds: Long

  51. val leaderImbalancePerBrokerPercentage: Integer

  52. val listeners: Map[SecurityProtocol, EndPoint]

  53. val logCleanerBackoffMs: Long

  54. val logCleanerDedupeBufferLoadFactor: Double

  55. val logCleanerDedupeBufferSize: Long

  56. val logCleanerDeleteRetentionMs: Long

  57. val logCleanerEnable: Boolean

  58. val logCleanerIoBufferSize: Integer

  59. val logCleanerIoMaxBytesPerSecond: Double

  60. val logCleanerMinCleanRatio: Double

  61. val logCleanerThreads: Integer

  62. val logCleanupIntervalMs: Long

  63. val logCleanupPolicy: String

  64. val logDeleteDelayMs: Long

  65. val logDirs: Seq[String]

  66. val logFlushIntervalMessages: Long

  67. val logFlushIntervalMs: Long

  68. val logFlushOffsetCheckpointIntervalMs: Long

  69. val logFlushSchedulerIntervalMs: Long

  70. val logIndexIntervalBytes: Integer

  71. val logIndexSizeMaxBytes: Integer

  72. val logPreAllocateEnable: Boolean

  73. val logRetentionBytes: Long

  74. val logRetentionTimeMillis: Long

  75. val logRollTimeJitterMillis: Long

  76. val logRollTimeMillis: Long

  77. val logSegmentBytes: Integer

  78. def logUnused(): Unit

    Definition Classes
    AbstractConfig
  79. val maxConnectionsPerIp: Integer

  80. val maxConnectionsPerIpOverrides: Map[String, Int]

  81. val maxReservedBrokerId: Int

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

  82. val messageMaxBytes: Integer

  83. val metricNumSamples: Integer

    ********* Metric Configuration *************

  84. val metricReporterClasses: List[MetricsReporter]

  85. val metricSampleWindowMs: Long

  86. val minInSyncReplicas: Integer

  87. final def ne(arg0: AnyRef): Boolean

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

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

    Definition Classes
    AnyRef
  90. val numIoThreads: Integer

  91. val numNetworkThreads: Integer

  92. val numPartitions: Integer

  93. val numQuotaSamples: Integer

  94. val numRecoveryThreadsPerDataDir: Integer

  95. val numReplicaFetchers: Integer

  96. val offsetCommitRequiredAcks: Short

  97. val offsetCommitTimeoutMs: Integer

  98. val offsetMetadataMaxSize: Integer

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

  99. val offsetsLoadBufferSize: Integer

  100. val offsetsRetentionCheckIntervalMs: Long

  101. val offsetsRetentionMinutes: Integer

  102. val offsetsTopicCompressionCodec: CompressionCodec

  103. val offsetsTopicPartitions: Integer

  104. val offsetsTopicReplicationFactor: Short

  105. val offsetsTopicSegmentBytes: Integer

  106. def originals(): Map[String, AnyRef]

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

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

    Definition Classes
    AbstractConfig
  109. val port: Integer

  110. val principalBuilderClass: Class[_]

    ********* SSL Configuration *************

  111. val producerPurgatoryPurgeIntervalRequests: Integer

  112. val producerQuotaBytesPerSecondDefault: Long

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

  113. val props: Map[_, _]

  114. val queuedMaxRequests: Integer

  115. val quotaWindowSizeSeconds: Integer

  116. val replicaFetchBackoffMs: Integer

  117. val replicaFetchMaxBytes: Integer

  118. val replicaFetchMinBytes: Integer

  119. val replicaFetchWaitMaxMs: Integer

  120. val replicaHighWatermarkCheckpointIntervalMs: Long

  121. val replicaLagTimeMaxMs: Long

  122. val replicaSocketReceiveBufferBytes: Integer

  123. val replicaSocketTimeoutMs: Integer

  124. val requestTimeoutMs: Integer

  125. val saslKerberosKinitCmd: String

  126. val saslKerberosMinTimeBeforeRelogin: Long

  127. val saslKerberosPrincipalToLocalRules: List[String]

  128. val saslKerberosServiceName: String

    ********* Sasl Configuration *************

  129. val saslKerberosTicketRenewJitter: Double

  130. val saslKerberosTicketRenewWindowFactor: Double

  131. val socketReceiveBufferBytes: Integer

  132. val socketRequestMaxBytes: Integer

  133. val socketSendBufferBytes: Integer

  134. val sslCipher: List[String]

  135. val sslClientAuth: String

  136. val sslEnabledProtocols: List[String]

  137. val sslKeyManagerAlgorithm: String

  138. val sslKeyPassword: Password

  139. val sslKeystoreLocation: String

  140. val sslKeystorePassword: Password

  141. val sslKeystoreType: String

  142. val sslProtocol: String

  143. val sslProvider: String

  144. val sslTrustManagerAlgorithm: String

  145. val sslTruststoreLocation: String

  146. val sslTruststorePassword: Password

  147. val sslTruststoreType: String

  148. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  149. val uncleanLeaderElectionEnable: Boolean

  150. def unused(): Set[String]

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

    Definition Classes
    AbstractConfig
  152. final def wait(): Unit

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  155. val zkConnect: String

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

  156. val zkConnectionTimeoutMs: Int

  157. val zkEnableSecureAcls: Boolean

  158. val zkSessionTimeoutMs: Int

  159. val zkSyncTimeMs: Int

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AbstractConfig

Inherited from AnyRef

Inherited from Any

Ungrouped