【kafka】Timeout of 60000ms expired before the position for partition could be determined

1.概述

某环境Flink无法连接kafka,然后报错如下

org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition maxwell-0 could be determined

查看topic详情是正常的。

调整 request.timeout也没有作用。

查看 kafka 偏移量 ，好像没有这个消费组，说明没有创建

bin/kafka-consumer-groups.sh