1 consumeFromWhere

消費者從那個位置開始消費。

• CONSUME_FROM_LAST_OFFSET
  第一次啟動從佇列最後位置消費，後續再啟動接著上次消費的進度開始消費
• CONSUME_FROM_FIRST_OFFSET
  第一次啟動從佇列初始位置消費，後續再啟動接著上次消費的進度開始消費
• CONSUME_FROM_TIMESTAMP
  第一次啟動從指定時間點位置消費，後續再啟動接著上次消費的進度開始消費

2 allocateMessageQueueStrategy

預設AllocateMessageQueueAveragely，Rebalance（輪詢）演算法實現策略。

3 subscription

訂閱

4 offsetStore

訊息進度儲存，儲存實際的偏移量，兩種實現。

5 consumeThreadMin/consumeThreadMax

預設10，消費執行緒池數量/預設20， 消費執行緒數量

6 consumeConcurrentlyMaxSpan/pullThresholdForQueue

• 預設值2000， 單佇列並行消費允許的最大跨度 /
  
• 預設1000，拉訊息本地佇列快取訊息最大數
  

7 pullInterval/pullBatchSize

預設0，拉訊息間隔，由於是長輪詢，所以為0，但是如果應用為了流控，也可以設定大於0的值，單位毫秒

• 預設32， 批量拉訊息，一次最多拉多少條
  

9 consumeMessageBatchMaxSize

預設1，批量消費，一次消費多少條訊息

參考

• https://www.jianshu.com/p/0948922a058d