60000ms专题

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 Ta