由于消息的消费方式有两种,所以两种方式也有不同的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(轮询)算法实现策略

最新文章

  1. Paypal开发中遇到请求被中止: 未能创建 SSL/TLS 安全通道及解决方案
  2. BZOJ2705: [SDOI2012]Longge的问题
  3. c# 写着玩的,两个Task并发,一个写队列一个读队列的异常情况
  4. iOS边练边学--父子控件之作为导航控制器的子类产生的问题以及网易新闻练习
  5. 利用TCP 客户端---->服务端 传送文件到指定路径,并返回一个友好的回馈
  6. BZOJ_1202_狡猾的商人_(并查集)
  7. hdoj 2502 月之数
  8. Chapter 3.单一职责原则
  9. 服务器 vps 空间
  10. BZOJ 1101 [POI2007]Zap ——Dirichlet积
  11. Hadoop与分布式数据处理 Spark VS Hadoop有哪些异同点?
  12. MySql常用操作语句(1:启动、连接数据库及用户操作)
  13. java main方法执行sql语句
  14. 【20190305】CSS-响应式图片:srcset+sizes,picture,svg
  15. Structured Streaming + Kafka Integration Guide 结构化流+Kafka集成指南 (Kafka broker version 0.10.0 or higher)
  16. mysql 存储过程、循环
  17. System.Action的使用(lambda 表达式)
  18. eclipse svn同步资源库时忽略某些不需要提交文件类型和文件夹
  19. jieba分词(2)
  20. JAVA中如何正确的用String转Date

热门文章

  1. Final 用法
  2. centos7的编译安装php5.3 (针对老系统必须安装php5.3才能运行)
  3. 训练1-R
  4. 3.1、Jinja2模板引擎
  5. 转[总结]FFMPEG视音频编解码零基础学习方法 .
  6. selenium+java实现浏览器前进、后退和刷新
  7. BA-协议-BACnet 协议优势简析
  8. PowerDesigner16 破解
  9. ASP.Net MVC – What are the uses of Display, DisplayName, DisplayFormat and ScaffoldColumn attributes
  10. HDOJ 2682 Tree(最小生成树prim算法)