python - 如何使用 kafka-python 检查消费者组中的活跃消费者数量？
问题描述
我有一个包含 15 个消费者的消费者组。当我开始这个过程时，这 15 个消费者在一分钟内处理了大约 200 条记录，但后来随着传入记录的数量下降，我相信消费者在空闲 540000ms 后开始失去连接。
我想看看有多少消费者在使用 kafka-python 的特定消费者组中仍然处于活动状态，以便我可以添加消费者以继续处理。同样可以在 shell 中使用 --member 命令完成，但我有兴趣在 kafka-python 中执行此操作。
解决方案
推荐阅读
- admin - Magento 2.3.3 仪表板不断加载
- java - 从数字中删除点 (.) 的正则表达式
- arduino - Arduino SPI接口读取随机值？（尝试使用 CAN 总线屏蔽）
- validation - 引导日期选择器结束日期不能超过开始日期后 1 年
- python - 将 Python 脚本连接到 Nodejs
- c - 通过 RS-232 的串行通信在一段时间后停止，无法传输数据，为什么？
- json - Jmeter 没有处理巨大的 JSON 有效负载
- python - XLRD 拆分单元格的逗号分隔值
- android - 使用firebase时面临颤振错误
- python - groupby 中的百分位数与命名聚合 pandas python