Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagescala
titlekafka.cluster.Broker
object Broker {
  private[cluster] case class ServerInfo(clusterResource: ClusterResource,
                                         brokerId: Int,
                                         endpoints: util.List[Endpoint],
                                         interBrokerEndpoint: Endpoint,
										 override val metrics: Metrics) extends AuthorizerServerInfo
}

case class Broker(id: Int, endPoints: Seq[EndPoint], rack: Option[String]) {
  ......
  def toServerInfo(clusterId: String, config: KafkaConfig, metrics: Metrics): AuthorizerServerInfo = {
    val clusterResource: ClusterResource = new ClusterResource(clusterId)
    val interBrokerEndpoint: Endpoint = endPoint(config.interBrokerListenerName).toJava
    val brokerEndpoints: util.List[Endpoint] = endPoints.toList.map(_.toJava).asJava
    Broker.ServerInfo(clusterResource, id, brokerEndpoints, interBrokerEndpoint, metrics)
  }
}

...

kafka.security.authorizer.AclAuthorizer will be updated for adding following Kafka metrics
Total Acls SensorMetric "acl-total-count" for reporting total numberacls of Acls created.
Total denied sensorMetric "authorization-request-rate-per-hour" for reporting total number of authorizeauthorization requests deniedper hour
TotalMetric "authorization-allowed sensor -rate-per-hour" for reporting total number of authorize requestsauthorization allowed
Total authorizeper requests sensorhour
Metric "authorization-denied-rate-per-hour" for reporting total number of authorization authorizedenied per requestshour

Compatibility, Deprecation, and Migration Plan

...