hyperf / hyperf/kafka

关于接入阿里云的Kafka,提示:Kafka send timeout.

Open
#10 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
PHP
Stars
7
Forks
4
PR merge metrics
No merged PRs in 30d

Description

### 问题:

> **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());
}
```
![image](https://user-images.githubusercontent.com/19256829/147711353-ba81e5cb-cd40-4ac8-b45d-3b87d0991681.png)
### `kafka.php`配置如下:
![image](https://user-images.githubusercontent.com/19256829/147743511-98f4818a-df0f-4fd5-b2db-8908406d66eb.png)

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.