107 Star 940 Fork 158

GVPhyperf / hyperf

 / 详情

一次性投递多条消息的问题

待办的
创建于  
2021-06-17 22:13

一、代码如下:
$producer->sendBatch([
new ProduceMessage('test', 'hyperf1_value', 'hyperf1_key'),
new ProduceMessage('test', 'hyperf2_value', 'hyperf2_key'),
new ProduceMessage('test', 'hyperf3_value', 'hyperf3_key'),
]);

二、错误如下:
Notice: Undefined index: in /var/www/hyperf/vendor/hyperf/kafka/src/Producer.php on line 204
[ERROR] Return value of Hyperf\Kafka\Producer::getMessageBrokerId() must be of the type int, null returned[204] in /var/www/hyperf/vendor/hyperf/kafka/src/Producer.php
[ERROR] #0 /var/www/hyperf/vendor/hyperf/kafka/src/Producer.php(197): Hyperf\Kafka\Producer->getMessageBrokerId(Object(longlang\phpkafka\Producer\ProduceMessage))
#1:获取到的header信息结构有问题,期待是字符串,得到的是数组:The requested offset is not within the range of offsets maintained by the server /var/www/hyperf/vendor/hyperf/kafka/src/Producer.php(101): Hyperf\Kafka\Producer->slitByBroker(Array)
#2:Apollo配置里面json格式配置中包含中文,导致json_decode解析失败:一次性投递多条消息的问题 [internal function]: Hyperf\Kafka\Producer->Hyperf\Kafka{closure}()
#3:Redis异步队列数据丢失 /var/www/hyperf/vendor/hyperf/kafka/src/Producer.php(149): Closure->call(Object(Hyperf\Kafka\Producer))
#4:命名模式下做部分数据库操作时异常 {main}

三、运行环境如下:
PHP 7.4.13 (cli) (built: Dec 1 2020 04:18:12) ( 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.5.9
Built => Dec 6 2020 23:04:53
coroutine => enabled
epoll => enabled
eventfd => enabled
signalfd => enabled
cpu_affinity => enabled
spinlock => enabled
rwlock => enabled
sockets => enabled
openssl => OpenSSL 1.1.1d 10 Sep 2019
http2 => enabled
pcre => enabled
zlib => 1.2.11
mutex_timedlock => enabled
pthread_barrier => enabled
futex => 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 => On => On
swoole.unixsock_buffer_size => 8388608 => 8388608
longlang/phpkafka v1.1.4 A kafka client. Support php-fpm and Swoole.

评论 (3)

qq54554980 创建了任务
qq54554980 关联仓库设置为hyperf/hyperf
展开全部操作日志

单条信息投递没有问题

@qq54554980 你更新到hyperf最新版版还会吗?我使用了你的代码,无法复现上面的问题

我也遇到了,楼主解决了吗?求解

登录 后才可以发表评论

状态
负责人
里程碑
Pull Requests
关联的 Pull Requests 被合并后可能会关闭此 issue
分支
开始日期   -   截止日期
-
置顶选项
优先级
参与者(3)
1442687 pandaliu111111 1594862282
PHP
1
https://gitee.com/hyperf/hyperf.git
git@gitee.com:hyperf/hyperf.git
hyperf
hyperf
hyperf

搜索帮助