This is an automated email from the ASF dual-hosted git repository.
rsivaram pushed a commit to branch 2.4
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.4 by this push:
new d7a5a6a MINOR: Change topic-exists log for CreateTopics from INFO to
DEBUG (#7666)
d7a5a6a is described below
commit d7a5a6a0ffc88c2d44793c95f9b038ebf3104644
Author: Rajini Sivaram <[email protected]>
AuthorDate: Mon Nov 11 09:16:09 2019 +0000
MINOR: Change topic-exists log for CreateTopics from INFO to DEBUG (#7666)
Reviewers: Ismael Juma <[email protected]>
---
core/src/main/scala/kafka/server/AdminManager.scala | 3 +++
1 file changed, 3 insertions(+)
diff --git a/core/src/main/scala/kafka/server/AdminManager.scala
b/core/src/main/scala/kafka/server/AdminManager.scala
index d9a1732..346a013 100644
--- a/core/src/main/scala/kafka/server/AdminManager.scala
+++ b/core/src/main/scala/kafka/server/AdminManager.scala
@@ -179,6 +179,9 @@ class AdminManager(val config: KafkaConfig,
CreatePartitionsMetadata(topic.name, assignments, ApiError.NONE)
} catch {
// Log client errors at a lower level than unexpected exceptions
+ case e: TopicExistsException =>
+ debug(s"Topic creation failed since topic '${topic.name}' already
exists.", e)
+ CreatePartitionsMetadata(topic.name, Map(),
ApiError.fromThrowable(e))
case e: ApiException =>
info(s"Error processing create topic request $topic", e)
CreatePartitionsMetadata(topic.name, Map(),
ApiError.fromThrowable(e))
