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

kafka-topic --describe fails for topic created by "produce"

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Minor
    • Resolution: Unresolved
    • Affects Version/s: 2.3.1
    • Fix Version/s: None
    • Component/s: admin
    • Labels:
      None
    • Environment:
      MacOS

      Description

      > kafka-topics --version
      
      2.3.1 (Commit:18a913733fb71c01)

       

      While producing to a topic that does not already exists

      producer.send("does-not-exists", "msg-1")
      

       

      broker creates the topic

      // partition file
      
      > ls /tmp/kafka-logs/
      does-not-exists-0

       

      If I try to list the topics, it shows also shows this new topic

      > kafka-topics --bootstrap-server localhost:9092 --list
      does-not-exists-0
      

      Now while trying to describe the topic that was auto-created the following error is thrown

       

      > kafka-topics --bootstrap-server localhost:9092 --topic does-not-exists --describe
      
      Error while executing topic command : org.apache.kafka.common.errors.UnknownServerException: The server experienced an unexpected error when processing the request.Error while executing topic command : org.apache.kafka.common.errors.UnknownServerException: The server experienced an unexpected error when processing the request.[2020-09-08 00:21:30,890] ERROR java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnknownServerException: The server experienced an unexpected error when processing the request. 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.TopicCommand$AdminClientTopicService.$anonfun$describeTopic$3(TopicCommand.scala:228) at kafka.admin.TopicCommand$AdminClientTopicService.$anonfun$describeTopic$3$adapted(TopicCommand.scala:225) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach$(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at kafka.admin.TopicCommand$AdminClientTopicService.describeTopic(TopicCommand.scala:225) at kafka.admin.TopicCommand$.main(TopicCommand.scala:66) at kafka.admin.TopicCommand.main(TopicCommand.scala)Caused by: org.apache.kafka.common.errors.UnknownServerException: The server experienced an unexpected error when processing the request. (kafka.admin.TopicCommand$)
       
      

      ```

       

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              swayamraina Swayam Raina
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated: