kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rsiva...@apache.org
Subject [kafka] branch 2.4 updated: MINOR: Change topic-exists log for CreateTopics from INFO to DEBUG (#7666)
Date Mon, 11 Nov 2019 09:18:44 GMT
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 <rajinisivaram@googlemail.com>
AuthorDate: Mon Nov 11 09:16:09 2019 +0000

    MINOR: Change topic-exists log for CreateTopics from INFO to DEBUG (#7666)
    
    Reviewers: Ismael Juma <ismael@juma.me.uk>
---
 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))


Mime
View raw message