RateController

IncrRateController

• 配置项说明:

1. name

   • 类型: 单行文本
   • 必须: 是
   • 默认值: com.qlangtech.tis.trigger.util.UnCacheString@627d35ff
   • 说明: 无

2. 暂停/恢复

   • 类型: 单选

   • 必须: 是

   • 默认值: false

   • 说明:

     选择暂停可暂停消费当前管道中事件，之后可选择恢复可重新开始消费管道中的事件

3. rateCfg

   • 类型: 单行文本

   • 必须: 是

   • 默认值: NoLimit

   • 说明:

     有以下以下选项可选择：

     1. RateLimit: 可设置每秒处理事件的最大上限，有效防止消息过载对处理器形成背压
     2. FloodDischarge: 对管道中的事件消息一律放行，不作任何处理，也就是泄洪，当DBA在上游数据库中进行大量数据订正操作，管道中有大量未经处理的消息，可开启此选项。
     3. NoLimit: 正常处理管道中的消息，不对管道中消息施加任何限制

   • 可选项说明: 可选FloodDischarge,NoLimit,RateLimit以下是详细说明：

     • FloodDischarge

     • NoLimit

     • RateLimit

       

       • 配置项说明:

       1. rateLimit

          • 类型: 整型数字
          • 必须: 是
          • 默认值: 10000
          • 说明: 每秒最多处理的事件记录数目，当实时任务启动之后，支持运行期动态调整该限流参数