diff --git a/core/src/main/scala/kafka/server/SharedServer.scala b/core/src/main/scala/kafka/server/SharedServer.scala index 3ba06f3600818..6fd69b4a0f34b 100644 --- a/core/src/main/scala/kafka/server/SharedServer.scala +++ b/core/src/main/scala/kafka/server/SharedServer.scala @@ -103,7 +103,7 @@ class SharedServer( @volatile var brokerMetrics: BrokerServerMetrics = _ @volatile var controllerServerMetrics: ControllerMetadataMetrics = _ @volatile var loader: MetadataLoader = _ - val snapshotsDiabledReason = new AtomicReference[String](null) + val snapshotsDisabledReason = new AtomicReference[String](null) @volatile var snapshotEmitter: SnapshotEmitter = _ @volatile var snapshotGenerator: SnapshotGenerator = _ @@ -166,7 +166,7 @@ class SharedServer( action = () => SharedServer.this.synchronized { Option(brokerMetrics).foreach(_.metadataLoadErrorCount.getAndIncrement()) Option(controllerServerMetrics).foreach(_.incrementMetadataErrorCount()) - snapshotsDiabledReason.compareAndSet(null, "metadata loading fault") + snapshotsDisabledReason.compareAndSet(null, "metadata loading fault") }) /** @@ -177,7 +177,7 @@ class SharedServer( fatal = true, action = () => SharedServer.this.synchronized { Option(controllerServerMetrics).foreach(_.incrementMetadataErrorCount()) - snapshotsDiabledReason.compareAndSet(null, "controller startup fault") + snapshotsDisabledReason.compareAndSet(null, "controller startup fault") }) /** @@ -189,7 +189,7 @@ class SharedServer( action = () => SharedServer.this.synchronized { Option(brokerMetrics).foreach(_.metadataApplyErrorCount.getAndIncrement()) Option(controllerServerMetrics).foreach(_.incrementMetadataErrorCount()) - snapshotsDiabledReason.compareAndSet(null, "initial broker metadata loading fault") + snapshotsDisabledReason.compareAndSet(null, "initial broker metadata loading fault") }) /** @@ -200,7 +200,7 @@ class SharedServer( fatal = true, action = () => SharedServer.this.synchronized { Option(controllerServerMetrics).foreach(_.incrementMetadataErrorCount()) - snapshotsDiabledReason.compareAndSet(null, "quorum controller fault") + snapshotsDisabledReason.compareAndSet(null, "quorum controller fault") }) /** @@ -269,7 +269,7 @@ class SharedServer( setFaultHandler(metadataPublishingFaultHandler). setMaxBytesSinceLastSnapshot(sharedServerConfig.metadataSnapshotMaxNewRecordBytes). setMaxTimeSinceLastSnapshotNs(TimeUnit.MILLISECONDS.toNanos(sharedServerConfig.metadataSnapshotMaxIntervalMs)). - setDisabledReason(snapshotsDiabledReason). + setDisabledReason(snapshotsDisabledReason). setThreadNamePrefix(s"kafka-${sharedServerConfig.nodeId}-"). build() _raftManager.register(loader)