kafkaTimeout of 60000ms expired before the position for partition could be determined
Posted 九师兄
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了kafkaTimeout of 60000ms expired before the position for partition could be determined相关的知识,希望对你有一定的参考价值。
文章目录
1.概述
某环境FLink无法连接kafka,然后报错如下
org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition maxwell-0 could be determined
查看topic详情是正常的。
调整 request.timeout
也没有作用。
查看 kafka 偏移量 ,好像没有这个消费组,说明没有创建
bin/kafka-consumer-groups.sh
以上是关于kafkaTimeout of 60000ms expired before the position for partition could be determined的主要内容,如果未能解决你的问题,请参考以下文章
E - Fantasy of a Summation LightOJ1213
scala中的Flink Kafka程序给出超时错误org.apache.kafka.common.errors.TimeoutException:60000毫秒后更新元数据失败
使用windows server2012时FileZilla客户端连接时报150 Opening data channel for directory listing of "/"
HikariPool-1 - Connection is not available, request timed out after XXXXms.