flink 通过API连接kafka 消费flink0-topic 数据问题
来源：4-8 Source API编程之对接Kafka数据
慕虎7472913
2021-07-18
Caused by: org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition flink-topic-0 could be determined
使用flink kafka source 连接阿里服务器上的kafka flink-topic 的时候报错, 这个怎么解决？
写回答
2回答
-
Michael_PK
2021-07-19
Timeout of 60000ms，显示超时，如下几个地方去检查下：
1）zk正常吗
2）kafka是否正常运行，使用自带的生产者和消费者进行测试
3）阿里云的安全策略是否已经添加的对应的kafka的端口了
00 -
MagicPenta
2021-07-18
阿里云 kafka 开公网访问了吗？建议先用 telnet 或者 kafka tool 工具，确认网络是通的。
032022-02-18
相似问题