THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
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
...