如何使用Java中的Kafka客户端显示主题？

问题描述

public static void main(String [] args){

Properties config = new Properties();

config.put(AdminClientConfig.BOOTSRAP._SERVERS_CONfig,"mybroker.ip.address:9092");

AdminClient admin = AdminClient.create(config);
ListTopicsResult ltr = admin.listTopics().names().get();

}

我正在捕获一个带有错误消息的ExecutionException：org.apache.kafka.common.errors.TimeoutException：Call（callName：listTopics，最后期限Ms = 1599813311360，try = 1，nextAllowedTryMs = -9223372034707292162）在1233之后在9223372036854775807超时尝试

StackTrace指向wrapAndThrow中的KafkaFutureImpl类。

由于我正在通过手机编写所有这些错误，因此我无法真正粘贴所有错误。

我正在使用Kafka Clients 2.6.0，JDK 1.8.0_191

这很奇怪，因为超时立即发生，而且我也尝试将参数传递给get（time，timeunit），并且得到相同的结果。

编辑： 我在POM中缺少一些依赖项。这样就解决了问题。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）