RocketMQ学习笔记(12)----RocketMQ的Consumer API简介
由于消息的消费方式有两种,所以两种方式也有不同的API:
1. PushConsumer的配置
1. consumerGroup: 默认值为DEFAULT_CONSUMER,Consumer组名,多个Consumer如果属于一个应用,订阅同样的消息,且消费逻辑一致,则应该将它们归为同一组
2. messageModel: 消息模型,默认值为CLUSTERING,支持集群消费,广播消费两种模型
3. consumeFromWhere: 默认值为CONSUME_FROM_LAST_OFFSET,Consumer启动后,默认从什么位置开始消费
4. allocateMessageQueueStrategy: 默认值AllocateMessageQueueAveragely,Rebalance(轮询)算法实现策略
5. subscription: 默认值{},订阅关系
6. messageListener: 消息监听器
7. offsetStore: 消息进度存储
8. consumeThreadMin: 默认10,消费线程池数量
9. consumeThreadMax: 默认20, 消费线程数量
10. consumeConcurrentlyMaxSpan: 默认值2000, 单队列并行消费允许的最大跨度
11. pullThresholdForQueue: 默认1000,拉消息本地队列缓存消息最大数
12. pullInterval: 默认0,拉消息间隔,由于是长轮询,所以为0,但是如果应用为了流控,也可以设置大于0的值,单位毫秒
13. consumeMessageBatchMaxSize: 默认1,批量消费,一次消费多少条消息
14. pullBatchSize: 默认32, 批量拉消息,一次最多拉多少条
2. PullConsumer的配置
1. consumerGroup: 默认DEFAULT_CONSUMER,Consumer组名,多个Consumer如果属于一个应用,订阅同样的消息,且消费逻辑一致,则应该将它们归为同一组。
2. brokerSuspendMaxTimeMillis:默认20000,长轮询,Consumer拉消息请求在Broker挂起最长时间,单位毫秒
3. consumerTimeoutMillisWhenSuspend: 默认30000,长轮询,Consumer拉消息请求在Broker挂起超过指定时间,客户端认为超时,单位毫秒
4. consumerPullTimeoutMillis: 默认10000,非长轮询,拉消息超时时间,单位毫秒
5. messageModel:默认值BROADCASTING,消息模型,支持以下集群消费 、广播消费两种模型
6. messageQueueListener: 监听队列变化
7. offsetStore: 消费进度存储
8. registerTopics:默认为[],注册的topic集合
9. allocateMessageQueueStrategy: 默认AllocateMessageQueueAveragely,Rebalance(轮询)算法实现策略
最新文章
- Paypal开发中遇到请求被中止: 未能创建 SSL/TLS 安全通道及解决方案
- BZOJ2705: [SDOI2012]Longge的问题
- c# 写着玩的,两个Task并发,一个写队列一个读队列的异常情况
- iOS边练边学--父子控件之作为导航控制器的子类产生的问题以及网易新闻练习
- 利用TCP 客户端---->;服务端 传送文件到指定路径,并返回一个友好的回馈
- BZOJ_1202_狡猾的商人_(并查集)
- hdoj 2502 月之数
- Chapter 3.单一职责原则
- 服务器 vps 空间
- BZOJ 1101 [POI2007]Zap ——Dirichlet积
- Hadoop与分布式数据处理 Spark VS Hadoop有哪些异同点?
- MySql常用操作语句(1:启动、连接数据库及用户操作)
- java main方法执行sql语句
- 【20190305】CSS-响应式图片:srcset+sizes,picture,svg
- Structured Streaming + Kafka Integration Guide 结构化流+Kafka集成指南 (Kafka broker version 0.10.0 or higher)
- mysql 存储过程、循环
- System.Action的使用(lambda 表达式)
- eclipse svn同步资源库时忽略某些不需要提交文件类型和文件夹
- jieba分词(2)
- JAVA中如何正确的用String转Date
热门文章
- Final 用法
- centos7的编译安装php5.3 (针对老系统必须安装php5.3才能运行)
- 训练1-R
- 3.1、Jinja2模板引擎
- 转[总结]FFMPEG视音频编解码零基础学习方法 .
- selenium+java实现浏览器前进、后退和刷新
- BA-协议-BACnet 协议优势简析
- PowerDesigner16 破解
- ASP.Net MVC – What are the uses of Display, DisplayName, DisplayFormat and ScaffoldColumn attributes
- HDOJ 2682 Tree(最小生成树prim算法)