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

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







发表于: 3月前   最后更新时间: 3月前   游览量:255
上一条: 到头了!
下一条: 已经是最后了!

评论…


  • 有多个消费者吗?
    • ## 显示某个消费组的消费详情(支持0.9版本+)
      bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group test-consumer-group

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