请稍等 ...
×

采纳答案成功!

向帮助你的同学说点啥吧!感谢那些助人为乐的人

老师 公司最近用的kafka

有一个疑问
生产者生产一个消息
消费者在消费的时候 收到消息 进行对消息的业务处理 比如增删改查 假如失败了怎么办?
如果依靠offset怎么办 怎么存储offset呢

有没有推荐的资料
网上的看遍了 关于php扩展这方面大同小异 所以在swoole里问了 望singwa老师不吝赐教

正在回答

插入代码

1回答

亲爱的同学您好:

kafka的consumer是主动拉取消息的,consumer端可以配置是自动还是手动提交offset,如果业务处理失败的话,可以通过自己记录重新入kafka或者其他手段来处理。资料看官方文档就行了


1 回复 有任何疑惑可以回复我~
  • 3Q老师!
    回复 有任何疑惑可以回复我~ 2019-03-14 14:35:47
  • https://arnaud-lb.github.io/php-rdkafka/phpdoc/rdkafka.examples-high-level-consumer.html
    $consumer->subscribe(['test']);  
    我把有个参数enable_auto_commit...设置为false了,然后执行上面的消费者demo,offset的值还是更新了,是正常的吗?
    回复 有任何疑惑可以回复我~ 2019-03-18 20:53:44
  • 试下回复效果
    回复 有任何疑惑可以回复我~ 2019-08-18 19:18:25
问题已解决,确定采纳
还有疑问,暂不采纳
意见反馈 帮助中心 APP下载
官方微信