任务运行时异常：org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition topic_name could be determined

问题描述/异常栈

2021-12-27 10:58:27
org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition topic_name could be determined

解决方案

测试集群节点与kafka的连通性，确保集群环境可以访问该kafka。

问题原因

一般为集群环境与该Topic所属kafka集群不互通导致。

作者：邓崃翔