Class/Object

kafka.server

KafkaServer

Related Docs: object KafkaServer | package server

Permalink

class KafkaServer extends Logging with KafkaMetricsGroup

Represents the lifecycle of a single Kafka broker. Handles all functionality required to start up and shutdown a single Kafka node.

Linear Supertypes
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. KafkaServer
  2. KafkaMetricsGroup
  3. Logging
  4. AnyRef
  5. Any
  1. Hide All
  2. Show all
Visibility
  1. Public
  2. All

Instance Constructors

  1. new KafkaServer(config: KafkaConfig, time: Time = SystemTime, threadNamePrefix: Option[String] = None)

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

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

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

    Permalink
    Definition Classes
    AnyRef → Any
  4. var apis: KafkaApis

    Permalink
  5. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  6. var authorizer: Option[Authorizer]

    Permalink
  7. def awaitShutdown(): Unit

    Permalink

    After calling shutdown(), use this API to wait until the shutdown is complete

  8. def boundPort(protocol: SecurityProtocol = SecurityProtocol.PLAINTEXT): Int

    Permalink
  9. val brokerMetaPropsFile: String

    Permalink
  10. val brokerMetadataCheckpoints: Map[String, BrokerMetadataCheckpoint]

    Permalink
  11. val brokerState: BrokerState

    Permalink
  12. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  13. val config: KafkaConfig

    Permalink
  14. var consumerCoordinator: GroupCoordinator

    Permalink
  15. val correlationId: AtomicInteger

    Permalink
  16. def debug(msg: ⇒ String, e: ⇒ Throwable): Unit

    Permalink
    Definition Classes
    Logging
  17. def debug(e: ⇒ Throwable): Any

    Permalink
    Definition Classes
    Logging
  18. def debug(msg: ⇒ String): Unit

    Permalink
    Definition Classes
    Logging
  19. var dynamicConfigHandlers: Map[String, ConfigHandler]

    Permalink
  20. var dynamicConfigManager: DynamicConfigManager

    Permalink
  21. final def eq(arg0: AnyRef): Boolean

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

    Permalink
    Definition Classes
    AnyRef → Any
  23. def error(msg: ⇒ String, e: ⇒ Throwable): Unit

    Permalink
    Definition Classes
    Logging
  24. def error(e: ⇒ Throwable): Any

    Permalink
    Definition Classes
    Logging
  25. def error(msg: ⇒ String): Unit

    Permalink
    Definition Classes
    Logging
  26. def fatal(msg: ⇒ String, e: ⇒ Throwable): Unit

    Permalink
    Definition Classes
    Logging
  27. def fatal(e: ⇒ Throwable): Any

    Permalink
    Definition Classes
    Logging
  28. def fatal(msg: ⇒ String): Unit

    Permalink
    Definition Classes
    Logging
  29. def finalize(): Unit

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

    Permalink
    Definition Classes
    AnyRef → Any
  31. def getLogManager(): LogManager

    Permalink
  32. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  33. def info(msg: ⇒ String, e: ⇒ Throwable): Unit

    Permalink
    Definition Classes
    Logging
  34. def info(e: ⇒ Throwable): Any

    Permalink
    Definition Classes
    Logging
  35. def info(msg: ⇒ String): Unit

    Permalink
    Definition Classes
    Logging
  36. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  37. var kafkaController: KafkaController

    Permalink
  38. var kafkaHealthcheck: KafkaHealthcheck

    Permalink
  39. val kafkaScheduler: KafkaScheduler

    Permalink
  40. var logIdent: String

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  41. var logManager: LogManager

    Permalink
  42. lazy val logger: Logger

    Permalink
    Definition Classes
    Logging
  43. val loggerName: String

    Permalink
    Definition Classes
    Logging
  44. val metadataCache: MetadataCache

    Permalink
  45. var metrics: Metrics

    Permalink
  46. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  47. def newGauge[T](name: String, metric: Gauge[T], tags: Map[String, String] = Map.empty): Gauge[T]

    Permalink
    Definition Classes
    KafkaMetricsGroup
  48. def newHistogram(name: String, biased: Boolean = true, tags: Map[String, String] = Map.empty): Histogram

    Permalink
    Definition Classes
    KafkaMetricsGroup
  49. def newMeter(name: String, eventType: String, timeUnit: TimeUnit, tags: Map[String, String] = Map.empty): Meter

    Permalink
    Definition Classes
    KafkaMetricsGroup
  50. def newTimer(name: String, durationUnit: TimeUnit, rateUnit: TimeUnit, tags: Map[String, String] = Map.empty): Timer

    Permalink
    Definition Classes
    KafkaMetricsGroup
  51. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  52. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  53. def removeMetric(name: String, tags: Map[String, String] = Map.empty): Unit

    Permalink
    Definition Classes
    KafkaMetricsGroup
  54. var replicaManager: ReplicaManager

    Permalink
  55. var requestHandlerPool: KafkaRequestHandlerPool

    Permalink
  56. def shutdown(): Unit

    Permalink

    Shutdown API for shutting down a single instance of the Kafka server.

    Shutdown API for shutting down a single instance of the Kafka server. Shuts down the LogManager, the SocketServer and the log cleaner scheduler thread

  57. var socketServer: SocketServer

    Permalink
  58. def startup(): Unit

    Permalink

    Start up API for bringing up a single instance of the Kafka server.

    Start up API for bringing up a single instance of the Kafka server. Instantiates the LogManager, the SocketServer and the request handlers - KafkaRequestHandlers

  59. def swallow(action: ⇒ Unit): Unit

    Permalink
    Definition Classes
    Logging
  60. def swallowDebug(action: ⇒ Unit): Unit

    Permalink
    Definition Classes
    Logging
  61. def swallowError(action: ⇒ Unit): Unit

    Permalink
    Definition Classes
    Logging
  62. def swallowInfo(action: ⇒ Unit): Unit

    Permalink
    Definition Classes
    Logging
  63. def swallowTrace(action: ⇒ Unit): Unit

    Permalink
    Definition Classes
    Logging
  64. def swallowWarn(action: ⇒ Unit): Unit

    Permalink
    Definition Classes
    Logging
  65. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  66. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  67. def trace(msg: ⇒ String, e: ⇒ Throwable): Unit

    Permalink
    Definition Classes
    Logging
  68. def trace(e: ⇒ Throwable): Any

    Permalink
    Definition Classes
    Logging
  69. def trace(msg: ⇒ String): Unit

    Permalink
    Definition Classes
    Logging
  70. final def wait(): Unit

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

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

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  73. def warn(msg: ⇒ String, e: ⇒ Throwable): Unit

    Permalink
    Definition Classes
    Logging
  74. def warn(e: ⇒ Throwable): Any

    Permalink
    Definition Classes
    Logging
  75. def warn(msg: ⇒ String): Unit

    Permalink
    Definition Classes
    Logging
  76. var zkUtils: ZkUtils

    Permalink

Inherited from KafkaMetricsGroup

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped