请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”，通常会是什么问题？

千鹤·重弹 发表于: 2018-06-20   最后更新时间: 2018-06-20  
  •   0 订阅，98 游览

现象是consumer的fetch请求没法发送了，很奇怪，把consumer线程杀掉重新fetch就好了







发表于: 29天前   最后更新时间: 29天前   游览量:98
上一条: 到头了!
下一条: 已经是最后了!
Avatar

评论…

评论

  • 半兽人 29天前
    有多个消费者吗？
    • 半兽人 千鹤·重弹 . 28天前
      ## 显示某个消费组的消费详情（支持0.9版本+）
      bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group test-consumer-group

      看看消费者占用情况。
        • 千鹤·重弹 半兽人 . 28天前
          这个查过了   对应发不出fetch请求的consumer lag值一直飙升  我们现在就是做了动态监控  当lag值大于某个阈值后热重启消费者。。但是这样太土了。。还是想找到根因
            • 千鹤·重弹 半兽人 . 28天前
              研究了下Fetcher的createFetchRequests方法（0.10）,应该是else if (this.client.pendingRequestCount(node) == 0) 这个分支没有进去。。Apache kafka源码剖析里也没有找到想要的答案，愁死了。。
                • 评论…
                • in this conversation
                  提交
                  提问