phpkafka
phpkafka copied to clipboard
kafka rejoin时,fetchMessages抛出警告修复方法讨论
- 你遇到了什么问题? 最近在使用kafka时,每次重启服务都会出现非常多warning;之前也有issue提到过#https://github.com/swoole/phpkafka/issues/92
- 个人建议有两种解决方法。
1、heartbeatTimerId为null时,不执行
fetchMessages方法
2、joinGroup时指定默认的memberId:因为group.instance.id只要没有发生变化,没必要每次rejoin都重新生成member.id
- 总结 请问这两种方法,哪种更优?或者有没有其他解决方案
这个没什么大问题的