[jira] [Commented] (KAFKA-10467) kafka-topic --describe fails for topic created by "produce"

["Luke Chen (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17192037#comment-17192037 ] 

Luke Chen commented on KAFKA-10467:
-----------------------------------

[~swayamraina] , your feed the wrong parameter into send method. The send needs *ProducerRecord* to send. Please check: [https://kafka.apache.org/26/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html#send-org.apache.kafka.clients.producer.ProducerRecord-]

 

So, the correct way should be:
{code:java}
producer.send(new ProducerRecord<>("topic", "key", "value"));
{code}

> kafka-topic --describe fails for topic created by "produce"
> -----------------------------------------------------------
>
>                 Key: KAFKA-10467
>                 URL: https://issues.apache.org/jira/browse/KAFKA-10467
>             Project: Kafka
>          Issue Type: Bug
>          Components: admin
>    Affects Versions: 2.3.1
>         Environment: MacOS 
>            Reporter: Swayam Raina
>            Priority: Minor
>
> {code:java}
> > kafka-topics --version
> 2.3.1 (Commit:18a913733fb71c01){code}
>  
> While producing to a topic that does not already exists
> {code:java}
> producer.send("does-not-exists", "msg-1")
> {code}
>  
> broker creates the topic
> {code:java}
> // partition file
> > ls /tmp/kafka-logs/
> does-not-exists-0{code}
>  
> If I try to list the topics, it shows also shows this new topic
> {code:java}
> > kafka-topics --bootstrap-server localhost:9092 --list
> does-not-exists-0
> {code}
> Now while trying to describe the topic that was auto-created the following error is thrown
>  
> {code:java}
> > 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$)
>  
> {code}
> ```
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)