具体错误如下：

Heartbeat failed: local member_id was not recognized; resetting and re-joining group
Heartbeat session expired - marking coordinator dead
Marking the coordinator dead (node 112583)for group fba_inventory_summary_data_report_sync_to_user_db.
OffsetCommit failed for group fba_inventory_summary_data_report_sync_to_user_db due to group error ([Error 25] UnknownMemberIdError: fba_inventory_summary_data_report_sync_to_user_db), will rejoin
OffsetCommit failed for group fba_inventory_summary_data_report_sync_to_user_db due to group error ([Error 25] UnknownMemberIdError: fba_inventory_summary_data_report_sync_to_user_db), will rejoin
OffsetCommit failed for group fba_inventory_summary_data_report_sync_to_user_db due to group error ([Error 25] UnknownMemberIdError: fba_inventory_summary_data_report_sync_to_user_db), will rejoin
OffsetCommit failed for group fba_inventory_summary_data_report_sync_to_user_db due to group error ([Error 25] UnknownMemberIdError: fba_inventory_summary_data_report_sync_to_user_db), will rejoin
Auto offset commit failed: [Error 25] UnknownMemberIdError: fba_inventory_summary_data_report_sync_to_user_db
OffsetCommit failed for group fba_inventory_summary_data_report_sync_to_user_db due to group error ([Error 25] UnknownMemberIdError: fba_inventory_summary_data_report_sync_to_user_db), will rejoin
OffsetCommit failed for group fba_inventory_summary_data_report_sync_to_user_db due to group error ([Error 25] UnknownMemberIdError: fba_inventory_summary_data_report_sync_to_user_db), will rejoin
OffsetCommit failed for group fba_inventory_summary_data_report_sync_to_user_db due to group error ([Error 25] UnknownMemberIdError: fba_inventory_summary_data_report_sync_to_user_db), will rejoin
OffsetCommit failed for group fba_inventory_summary_data_report_sync_to_user_db due to group error ([Error 25] UnknownMemberIdError: fba_inventory_summary_data_report_sync_to_user_db), will rejoin
OffsetCommit failed before join, ignoring: CommitFailedError: ('Commit cannot be completed since the group has already\n            rebalanced and assigned the partitions to another member.\n            This means that the time between subsequent calls to poll()\n            was longer than the configured max_poll_interval_ms, which\n            typically implies that the poll loop is spending too much\n            time message processing. You can address this either by\n            increasing the rebalance timeout with max_poll_interval_ms,\n            or by reducing the maximum size of batches returned in poll()\n            with max_poll_records.\n            ', 'Commit cannot be completed since the group has already rebalanced and may have assigned the partitions to another member')

错误分析：

根据错误信息的提示是max_poll_interval_ms设置太小，但经过修改后发现并不是这个原因；

再次查看错误信息，怀疑是消费组心跳没有发送/发送心跳超市导致服务端认为消费组已经死亡，从而当消费组发起心跳后会出现异常。

解决：

1.修改了很多消费组的配置，诸如session_timeout_ms、max_poll_interval_ms，最终都没有什么效果；

并且session_timeout_ms设置过大还会造成另外的问题：

Error sending JoinGroupRequest_v2 to node 112581 [[Error 7] RequestTimedOutError] -- marking coordinator dead

2. 最终只有了一个治标的方法：在耗时并且只能同步执行的代码处加入0.1睡眠时间，这0.1秒的睡眠时间可以让消费组去发送心跳

其他

如果其他更好的解决方案，欢迎在评论区中评论一下

aiokafka：Heartbeat failed: local member_id was not recognized； resetting and re-joining group相关推荐

windows10下编译dllib报错： ERROR: Failed building wheel for dlib
一.报错信息在安装dlib的时候,使用pip进行安装 pip install dlib 二.解决方式 1.检查自己是否已经安装了cmake 首先要检测自己本机是否已经安装了cmake,因为安装dli ...
【已解决】github中git push origin master出错：error: failed to push some refs to(亲测)
[背景] 折腾: [记录]将googlecode上面的crifanLib迁移到Github上期间出错: ? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 ...
Bad Request: amp;quot;requirement failed: Local path /root/.livy-sessions/
核心代码如下,问题是提交本地代码时报错: Bad Request: "requirement failed: Local path /root/.livy-sessions/61a5e39c ...
Windows安装pyav报错：ERROR: Failed building wheel for av.Failed to build av. ERROR: Could not build wheel
Windows安装pyav报错:ERROR: Failed building wheel for av.Failed to build av. ERROR: Could not build wheel ...
nginx php 104,Nginx错误：recv() failed (104: Connection reset by peer) whi
Nginx错误:recv() failed (104: Connection reset by peer) while reading response header from upstream PH ...
pycharm中报错：Error: failed to send plot to http://127.0.0.1:63342
pycharm中报错:Error: failed to send plot to http://127.0.0.1:63342 import matplotlib.pyplot as plt impo ...
cordova编译报错：Execution failed for task ':processDebugResources'
cordova编译报错:Execution failed for task ':processDebugResources' 引发这个错误的最扩祸首就是一个中文命名的文件,不知道什么时候加入的,我写了 ...
启动docker容器时报错：iptables failed: iptables --wait -t nat -A DOCKER -p tcp -d 0/0 --dport 5000 -j DNAT -
启动docker容器时报错: iptables failed: iptables --wait -t nat -A DOCKER -p tcp -d 0/0 --dport 5000 -j DNAT ...
VUE向django发送post返回403：CSRF Failed: CSRF token missing or incorrect
这是比较麻烦的一个问题, Vue+Django前后端分离的工程, 最终方案-后端: backend/goods/views.py: from django.views.decorators.csrf ...

aiokafka：Heartbeat failed: local member_id was not recognized； resetting and re-joining group

其他

aiokafka：Heartbeat failed: local member_id was not recognized； resetting and re-joining group相关推荐

最新文章

热门文章