开发者社区> 问答> 正文

Consumer

Consumer

本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击链接欢迎加入感兴趣的技术领域群。

展开
收起
游客pklijor6gytpx 2019-11-05 16:12:10 2069 0
4 条回答
写回答
取消 提交回答
  • 消费者在消费的过程中需要记录自己消费了多少数据,即消费位置信息。在Kafka中这个位置信息有个专门的术语:位移(offset)。很多消息引擎都把这部分信息保存在服务器端(broker端)。这样做的好处当然是实现简单

    2020-04-24 23:46:25
    赞同 展开评论 打赏
  • 对consumer有个问题。 设置properties.put(PropertyKeyConst.ConsumeThreadNums, 4); 实际线程数是68。 想知道线程数都与什么有关系。 使用的是 com.aliyun.openservices.ons.api.ONSFactory

    2019-11-27 14:34:07
    赞同 展开评论 打赏
  • 为之则易,不为则难

    Consumer:消费生产者生产的消息,rocketmq中有两种方式消费消息,一种是PullConsumer主动从消息队列中pull消息,另一种PushConsumer,是消息队列服务器主动推送到consumer端进行消费。

    2019-11-07 13:51:34
    赞同 展开评论 打赏
  • 消息消费者,简单来说,消费 MQ 上的消息的应用程序就是消费者

    2019-11-05 16:12:38
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载