当前位置:   article > 正文

【kafka】Timed out waiting for a node assignment_timed out waiting for a node assignment. call: des

timed out waiting for a node assignment. call: describetopics

在这里插入图片描述

1.概述

d8ecf8f7cdd8d9b7e0826c850ad06ad8.gif 535eeda53630e8537f22b0d62955c5fa.gif 0e3916616ab817aa003fb7fd1f121978.gif

在做flink任务的时候,报错 Timed out waiting for a node assignment 详细错误如下

在这里插入图片描述

2.源码

在SourceCoordinator中我们调用了start方法启动.启动方法主要做了2件事

  1. 创建Enumerator
  2. 启动Enumerator
    声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/繁依Fanyi0/article/detail/816104
    推荐阅读
    相关标签
      

    闽ICP备14008679号