kafkakafka 查看 GroupCoordinator 以及 kafka Group dead 消费组死掉 以及 GroupCoordinatorRequest 使用

Posted 2021-11-09 九师兄

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

文章目录

• 1.概述
• 2.主类
• • 2.1 乌龙测试
  • 2.2 正常返回节点
  • 2.3 小结

1.概述

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

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

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