From c8cfc26cb0e9b90147985fcbba27ec8139a5eb62 Mon Sep 17 00:00:00 2001 From: Rajini Sivaram Date: Thu, 16 Jan 2020 11:22:37 +0000 Subject: [PATCH] MINOR: Suppress DescribeConfigs Denied log during CreateTopics --- core/src/main/scala/kafka/server/KafkaApis.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/server/KafkaApis.scala b/core/src/main/scala/kafka/server/KafkaApis.scala index 4285a01b070c3..5cbd567ec17bc 100644 --- a/core/src/main/scala/kafka/server/KafkaApis.scala +++ b/core/src/main/scala/kafka/server/KafkaApis.scala @@ -1657,7 +1657,7 @@ class KafkaApis(val requestChannel: RequestChannel, val hasClusterAuthorization = authorize(request, CREATE, CLUSTER, CLUSTER_NAME, logIfDenied = false) val topics = createTopicsRequest.data.topics.asScala.map(_.name) val authorizedTopics = if (hasClusterAuthorization) topics.toSet else filterAuthorized(request, CREATE, TOPIC, topics.toSeq) - val authorizedForDescribeConfigs = filterAuthorized(request, DESCRIBE_CONFIGS, TOPIC, topics.toSeq) + val authorizedForDescribeConfigs = filterAuthorized(request, DESCRIBE_CONFIGS, TOPIC, topics.toSeq, logIfDenied = false) .map(name => name -> results.find(name)).toMap results.asScala.foreach(topic => {