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

新民工涛哥

21220人浏览 · 2020-06-09 11:40:58

新民工涛哥 · 2020-06-09 11:40:58 发布

错误：

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