老师这个错误是怎么回事啊

来源：4-6 查看Topic列表及Internal杂谈

qq_慕莱坞4316410

2020-09-23

Exception in thread “main” java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Call(callName=listTopics, deadlineMs=1600864667942) timed out at 1600864667943 after 1 attempt(s)
at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
at org.apache.kafka.common.internals.KafkaFutureImpl.access $000 (K a f k a F u t u r e I m p l . j a v a : 32) a t o r g . a p a c h e . k a f k a . c o m m o n . i n t e r n a l s . K a f k a F u t u r e I m p l$ SingleWaiter.await(KafkaFutureImpl.java:89)
at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260)
at com.imooc.server.server.kafak.test.admin.AdminSample.lookTopic(AdminSample.java:45)
at com.imooc.server.server.kafak.test.admin.AdminSample.main(AdminSample.java:24)
Caused by: org.apache.kafka.common.errors.TimeoutException: Call(callName=listTopics, deadlineMs=1600864667942) timed out at 1600864667943 after 1 attempt(s)
Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

代码：
public static void lookTopic() throws ExecutionException, InterruptedException {
AdminClient adminClient= createAdmin();
ListTopicsResult listTopicsResult=adminClient.listTopics();
Setnames=listTopicsResult.names().get();

     names.stream().forEach(System.out::println);

}

写回答

1回答

Allen

2020-09-24

连接超时嘛，看一下防火墙和配置之类的内容是不是对的

Jovan_C

qq_慕莱坞4316410

厉害果然关了就好了

2022-05-26

共2条回复

Kafka多维度系统精讲，从入门到实战开发

系统讲解Kafka，实战结合，让你成为使用Kafka的高手

896 学习 · 237 问题

查看课程

相似问题

老师，日志重复输出问题

回答 2

describeTopics报错

回答 1

关于kafka集群isr经常只剩一个的问题

回答 1

创建connector报错

回答 3

老师提供的kafka配置文档有一处错误

回答 1

打开慕课网App查看更多内容