问题:
1. 当给一个不存在的Topic投递时,会卡死并且返回Kafka send timeout.,Topic在阿里云kafka消息队列控制台提前创建好就没问题!
2. hyperf框架启动30-50秒左右才会进行消费!
环境:
Hyperf:2.2.14
Swoole:4.8.5
代码如下:
try {
$producer->send('test111', '投递成功,但是这一步超时了!', 'key');
} catch (\Exception $exception) {
return output_error($exception->getMessage());
}

kafka.php配置如下:
