admin管理员组

文章数量:1610831

文章目录

  • 1.概述
  • 2.场景2
  • 3. 场景3
  • 4.场景4
  • 5.场景5
  • 6.场景6
  • 7.场景7

1.概述

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

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

查看topic详情是正常的。


调整 request.timeout也没有作用。

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

bin/kafka-consumer-groups.

本文标签： msKafkatimeoutpartitiondetermined

版权声明：本文标题：【kafka】Timeout of 60000ms expired before the position for partition could be determined 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://www.elefans.com/dianzi/1728604598a1165292.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。