赞
踩
本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载。
因为这篇博客: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
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。