flink kafka报错Timeout of 60000ms expired before the position for partition could be determined

本文主要是介绍flink kafka报错Timeout of 60000ms expired before the position for partition could be determined，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

错误：

org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition skynetdbus-flink-test-1 could be determined

原因

kafka的 该topic 的partition数量大于flink TaskManager中可用的slot数量

修改方法

增加Flink slot数或者新建topic，减少topic的partiotion

这篇关于flink kafka报错Timeout of 60000ms expired before the position for partition could be determined的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---