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

swoole / phpkafka

PHP Kafka client is used in PHP-FPM and Swoole. PHP Kafka client supports 50 APIs, which might be one that supports the most message types ever.

https://longlang.org/

Apache License 2.0

271 stars 47 forks source link

Open xingcy08 opened 1 year ago

xingcy08 commented 1 year ago

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

看了源码是没有加重试次数导致的无限循环

xingcy08 commented 1 year ago

@limingxinleo

limingxinleo commented 1 year ago

好，我这周看看

jdbaha commented 1 year ago

yeap, if you disable the flag, there will be no infinite loop

over-star commented 3 months ago