当前位置:   article > 正文

【kafka】kafka 查看 GroupCoordinator 以及 kafka Group dead 消费组死掉 以及 GroupCoordinatorRequest 使用_group bankoper transitioned to dead in generation

group bankoper transitioned to dead in generation 84 (kafka.coordinator.grou

本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载。


在这里插入图片描述

1.概述

因为这篇博客:kafka通过java api 获取当前消费组offset/logsize/lag信息,实现消费延迟监控 我看到了,客户端可以发送 OffsetFetchResponse 请求。

然后追踪这个代码的时候发现构建BlockingChannel的时候,其实是一个SocketChannel.

然后实际生产中,我经常遇到消费组死掉。然后消费组死掉的话,经常有以下几个问题。

【kafka】消费组 死掉 kafka Marking the coordinator dead for group

【FLink】Flink 消费 kafka 消费组 死掉 Marking the coordinator dead for group 造成数据重复消费

然后消费组死掉,会打印日志

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

    闽ICP备14008679号