[
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)
