1.概述
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