消费者过段时间就报错

CXW0504 commented 3 years ago

你遇到了什么问题？ vendor/longlang/phpkafka/src/Client/SwooleClient.php(135): longlang\phpkafka\Socket\SwooleSocket->recv()

1 {main}

thrown in /opt/code/novel/vendor/longlang/phpkafka/src/Socket/SwooleSocket.php on line 128 PHP Fatal error: Uncaught longlang\phpkafka\Exception\SocketException: Could not recv data from stream,
Kafka 环境是自建还是云服务？

docker自建

请执行下面的命令获取环境信息。

php -v & php --ri swoole & composer info | grep longlang/phpkafka

# 粘贴到这里

 php -v & php --ri swoole & composer info | grep longlang/phpkafka
[1] 8319
[2] 8320
PHP 7.4.24 (cli) (built: Oct  7 2021 05:44:58) ( NTS )
Copyright (c) The PHP Group
Zend Engine v3.4.0, Copyright (c) Zend Technologies

swoole

Swoole => enabled
Author => Swoole Team <team@swoole.com>
Version => 4.7.1
Built => Oct  7 2021 05:50:26
coroutine => enabled with boost asm context
epoll => enabled
eventfd => enabled
signalfd => enabled
cpu_affinity => enabled
spinlock => enabled
rwlock => enabled
sockets => enabled
openssl => OpenSSL 1.1.1  11 Sep 2018
dtls => enabled
http2 => enabled
json => enabled
curl-native => enabled
pcre => enabled
zlib => 1.2.11
mutex_timedlock => enabled
pthread_barrier => enabled
futex => enabled
mysqlnd => enabled
async_redis => enabled

Directive => Local Value => Master Value
swoole.enable_coroutine => On => On
swoole.enable_library => On => On
swoole.enable_preemptive_scheduler => Off => Off
swoole.display_errors => On => On
swoole.use_shortname => Off => Off
swoole.unixsock_buffer_size => 8388608 => 8388608
longlang/phpkafka                  v1.2.0    A kafka client. Support php-fpm and Swoole.
[1]-  Done                    php -v
[2]+  Done                    php --ri swoole

* 提供最小可复现代码：

```php
// 你的代码