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

错误：

org.mon.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》对你有帮助，请点赞、收藏，并留下你的观点哦！