Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-12454

Add ERROR logging on kafka-log-dirs when given brokerIds do not exist in current kafka cluster

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • None
    • 3.0.0
    • None
    • None

    Description

      When non-existent brokerIds value are given, the kafka-log-dirs tool will have a timeout error:

      Exception in thread "main" java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: describeLogDirs
      at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
      at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
      at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
      at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260)
      at kafka.admin.LogDirsCommand$.describe(LogDirsCommand.scala:50)
      at kafka.admin.LogDirsCommand$.main(LogDirsCommand.scala:36)
      at kafka.admin.LogDirsCommand.main(LogDirsCommand.scala)
      Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: describeLogDirs

       

      When the brokerId entered by the user does not exist, an error message indicating that the node is not present should be printed.

      Attachments

        Issue Links

          Activity

            People

              wenbing.shen Wenbing Shen
              wenbing.shen Wenbing Shen
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: