flink 通过API连接kafka 消费flink0-topic 数据问题

Question

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 的时候报错, 这个怎么解决？

Answer 1

Michael_PK 2021-07-19 22:27:34

 Timeout of 60000ms，显示超时，如下几个地方去检查下：

1）zk正常吗

2）kafka是否正常运行，使用自带的生产者和消费者进行测试

3）阿里云的安全策略是否已经添加的对应的kafka的端口了

Answer 2

MagicPenta 2021-07-18 20:06:02

阿里云 kafka 开公网访问了吗？建议先用 telnet 或者 kafka tool 工具，确认网络是通的。

• 提问者 慕虎7472913 #1

  网络端口已经打开了，提示的错误信息是分片位置找不到错误。连接没有问题。

• weixin_慕圣3279781 回复 提问者 慕虎7472913 #2

  你这个问题解决了吗？我也遇到了同样的问题

• 慕莱坞9397895 回复 weixin_慕圣3279781 #3

  本地hosts表配置远程kafka机器和zookeeper的hostname试一下