phpkafka

phpkafka copied to clipboard

* 你遇到了什么问题？ 消费某个主题的某个分区数据无法实现 * Kafka 环境是自建还是云服务？ 自建 * 请执行下面的命令获取环境信息。 > `php -v & php --ri swoole & composer info | grep longlang/phpkafka` ``` # 粘贴到这里 [1] 71788 [2] 71789 PHP...

yyforeveryl

* What problem did you encounter? I'm trying to integrate Kafka producer with Laravel worker. After starting my worker, I noticed that publishing to Kafka is failing with following exception...

karunk-hq

当向一个不存在的 topic 生产消息时导致无限循环最后内存溢出

4

* 你遇到了什么问题？ 当在代码里设置了 ->setAutoCreateTopic(false) 时或者 kafka 服务器禁止了自动创建 topic 时，生产一个不存在的 topic 导致死循环最后内存溢出 看了源码是没有加重试次数导致的无限循环

xingcy08

* 你遇到了什么问题？ 我使用的是php-fpm , 我手动开了三个文件分别消费数据,昨天开始执行,今天过来发现出现以下报错 三个都是 Uncaught longlang\phpkafka\Exception\KafkaErrorException: [25] The coordinator is not aware of this member. * Kafka 环境是自建还是云服务？ 没装kafka环境,只使用了kafka的消费,消费第三方接口的数据 * 请执行下面的命令获取环境信息。 > `php -v & php --ri swoole...

shuaiki

* 你遇到了什么问题？ 请问支持设置以下kafka的producer端配置么。 1 retries 就是producer重试的次数设置 2 max.in.flight.requests.per.connection producer的IO线程在单个Socket连接上能够发送未应答produce请求的最大数量 在代码里面没看到有地方可以设置

nazrydirunn

消费kafka数据每隔一小时出现内存溢出问题

1

* 你遇到了什么问题？ Fatal error: Allowed memory size of 1073741824 bytes exhausted (tried to allocate 16777224 bytes) in /opt/www/vendor/longlang/phpkafka/src/Broker.php on line 142 * Kafka 环境是自建还是云服务？ AWS MSk 云服务 * 请执行下面的命令获取环境信息。 >...

Drogenwei