[jira] [Commented] (KAFKA-10467) kafka-topic --describe fails for topic created by "produce"
[
https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194483#comment-17194483
]
Swayam Raina commented on KAFKA-10467:
--
> did it happen in the latest version of Kafka?
> kafka-topics --version
2.3.1 (Commit:18a913733fb71c01)
I was running Kafka from sources in debug mode
> 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)
[jira] [Commented] (KAFKA-10467) kafka-topic --describe fails for topic created by "produce"
[
https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193292#comment-17193292
]
Luke Chen commented on KAFKA-10467:
---
> Any idea what causes this?
-> Sorry, I cannot reproduce it in my local env, did it happen in the latest
version of Kafka?
> Also, can anyone provide an insight into why would produce in a non-existent
> topic result in topic creation?
-> It's because *auto.create.topics.enable* is default set to true, which will
auto create topics if the topic doesn't exist and you're trying to
produce/consume message to/from the topic. You can set it to false if you don't
want this behavior.
Ref: https://kafka.apache.org/documentation/#auto.create.topics.enable
> 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)
[jira] [Commented] (KAFKA-10467) kafka-topic --describe fails for topic created by "produce"
[
https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193116#comment-17193116
]
Swayam Raina commented on KAFKA-10467:
--
Any idea what causes this?
Also, can anyone provide an insight into why would produce in a non-existent
topic result in topic creation?
> 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)
[jira] [Commented] (KAFKA-10467) kafka-topic --describe fails for topic created by "produce"
[
https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192630#comment-17192630
]
Swayam Raina commented on KAFKA-10467:
--
[~huxi_2b] the topic gets created by the broker and exists (see description)
> 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)
[jira] [Commented] (KAFKA-10467) kafka-topic --describe fails for topic created by "produce"
[
https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192585#comment-17192585
]
huxihx commented on KAFKA-10467:
Seems the problem is caused by another issue since it should have thrown `Topic
'does-not-exists' does not exist as expected`. Could you manually create a
topic using TopicCommand and then describe it to see if everything works?
> 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)
[jira] [Commented] (KAFKA-10467) kafka-topic --describe fails for topic created by "produce"
[
https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192282#comment-17192282
]
Swayam Raina commented on KAFKA-10467:
--
Hi [~showuon],
I was using an internal library which calls this method
{code:java}
public Future send(ProducerRecord record, Callback
callback){code}
The above method is responsible for creating ProducerRecord.
> 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)
[jira] [Commented] (KAFKA-10467) kafka-topic --describe fails for topic created by "produce"
[
https://issues.apache.org/jira/browse/KAFKA-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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)
