采纳答案成功!
向帮助你的同学说点啥吧!感谢那些助人为乐的人
有一个疑问 生产者生产一个消息消费者在消费的时候 收到消息 进行对消息的业务处理 比如增删改查 假如失败了怎么办?如果依靠offset怎么办 怎么存储offset呢有没有推荐的资料网上的看遍了 关于php扩展这方面大同小异 所以在swoole里问了 望singwa老师不吝赐教
亲爱的同学您好:
kafka的consumer是主动拉取消息的,consumer端可以配置是自动还是手动提交offset,如果业务处理失败的话,可以通过自己记录重新入kafka或者其他手段来处理。资料看官方文档就行了
3Q老师!
https://arnaud-lb.github.io/php-rdkafka/phpdoc/rdkafka.examples-high-level-consumer.html $consumer->subscribe(['test']); 我把有个参数enable_auto_commit...设置为false了,然后执行上面的消费者demo,offset的值还是更新了,是正常的吗?
试下回复效果
登录后可查看更多问答,登录/注册
swoole创始人推荐,借助Swoole打造高性能直播平台
1.8k 18
1.1k 13
1.9k 13
1.2k 13
1.0k 13