kafka
kafka copied to clipboard
easy-swoole
如标题，在源码中未找到可以设置 auth.commit 为 false 的部分，无法设置消费者手动提交消息的功能，可否增加该功能
具体的报错代码是all brokers are unreachable, 从SyncMeta/Process.php来的, 看报错内容像是客户端连接失败. 举个实际的例子, 100个并发压测200个请求, 有可能只能跑150个请求, 剩下50个请求全部抛all brokers are unreachable和Connect to Kafka server ip:port failed: Connection timed out
```Fatal error: Uncaught EasySwoole\Kafka\Exception\Exception: unpack failed. string(raw) length is 0 , TO s in /var/www/vendor/easyswoole/kafka/src/Protocol/Protocol.php:260 Stack trace: #0 /var/www/vendor/easyswoole/kafka/src/Protocol/Protocol.php(185): EasySwoole\Kafka\Protocol\Protocol::checkLen('s', '') #1 /var/www/vendor/easyswoole/kafka/src/Protocol/GroupCoordinator.php(43): EasySwoole\Kafka\Protocol\Protocol::unpack('s', '') #2 /var/www/vendor/easyswoole/kafka/src/Protocol.php(282): EasySwoole\Kafka\Protocol\GroupCoordinator->decode('') #3 /var/www/vendor/easyswoole/kafka/src/Group/Process.php(52):...
```Warning: Invalid argument supplied for foreach() in /var/www/vendor/easyswoole/kafka/src/Fetch/Process.php on line 54 Fatal error: Uncaught EasySwoole\Kafka\Exception\Protocol: given fetch data invalid. `partitions` is undefined. in /var/www/vendor/easyswoole/kafka/src/Protocol/Fetch.php:336 Stack trace: #0 /var/www/vendor/easyswoole/kafka/src/Protocol/Protocol.php(333): EasySwoole\Kafka\Protocol\Fetch->encodeFetchTopic(Array) #1...
目前出现了两次，突然间就不消费了。 打开kafka的server log： [2020-05-30 00:00:00,004] INFO [GroupCoordinator 0]: Preparing to rebalance group UserCenterProd in state PreparingRebalance with old generation 45617525 (__consumer_offsets-25) (reason: Updating metadata for member Easyswoole-kafka-42496b59-1170-487b-8b2a-21d8d460d2e9) (kafka.coordinator.group.GroupCoordinator) [2020-05-30 00:00:00,005]...
