We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
用supervisor维护常驻进程,在正常消费一段时间后,会报这个错误而结束进程
环境:php8.2,laravel 10.8 使用包版本:v1.2.2
` Pulsar\Exception\IOException
write data of close socket
at vendor/ikilobyte/pulsar-client-php/src/IO/StreamIO.php:123 119▕ } 120▕ 121▕ $size = @fwrite($this->socket, $buffer); 122▕ if ($size === false) { ➜ 123▕ throw new IOException('write data of close socket'); 124▕ } 125▕ 126▕ return $this; 127▕ }
+3 vendor frames
4 app/Console/PulsarConsumers/DbChangeWatcher2Command.php:62 Pulsar\Consumer::receive() +12 vendor frames
17 artisan:35 Illuminate\Foundation\Console\Kernel::handle(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
`
The text was updated successfully, but these errors were encountered:
@chenmingjian123 你看下是不是和这个一样,#1
Sorry, something went wrong.
不一样的,我们不在swoole环境,是用supervisor维护的进程
No branches or pull requests
用supervisor维护常驻进程,在正常消费一段时间后,会报这个错误而结束进程
环境:php8.2,laravel 10.8
使用包版本:v1.2.2
` Pulsar\Exception\IOException
write data of close socket
at vendor/ikilobyte/pulsar-client-php/src/IO/StreamIO.php:123
119▕ }
120▕
121▕ $size = @fwrite($this->socket, $buffer);
122▕ if ($size === false) {
➜ 123▕ throw new IOException('write data of close socket');
124▕ }
125▕
126▕ return $this;
127▕ }
4 app/Console/PulsarConsumers/DbChangeWatcher2Command.php:62
Pulsar\Consumer::receive()
+12 vendor frames
17 artisan:35
Illuminate\Foundation\Console\Kernel::handle(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
`
The text was updated successfully, but these errors were encountered: