我使用的是storm kafka客户端1.1.1和storm core 1.1.0。
我已经调整了以下参数，但无法启用背压和减少Kafka喷口的摄取率。
每秒消耗2000条消息。
下游螺栓处理一条消息需要50毫秒，即每秒处理20条消息。
喷口发射元组和螺栓执行元组之间的延迟随着时间的推移而增加。

我怎样才能让spoutread每秒读20条消息，并保持其消耗率与bolt的执行率相同

**Topology**

   topology.max.spout.pending=**5**, 
   topology.message.timeout.secs=**600**, 
   topology.executor.send.buffer.size=**64**, 
   topology.executor.receive.buffer.size=**64**, 
   topology.transfer.buffer.size=**64**

 **KafkaSpoutConfig**

   setPollTimeoutMs(**200**) , 
   setFirstPollOffsetStrategy(latest) , 
   setMaxUncommittedOffsets(**2_000_000**) , 
   setGroupId(groupName) , 
   setProp("fetch.max.wait.ms",**1000**) , 
   setProp("max.poll.records",**100**) , 
   setMaxPartitionFectchBytes(**512**)  , 
   setProp("send.buffer.bytes",**512**) , 
   setProp("receive.buffer.bytes",**512**) , 
   setPartitionRefreshPeriodMs(30_000).setProp("enable.auto.commit", "true") , 
   setProp("session.timeout.ms", "**60000**") , 

   KafkaSpoutRetryExponentialBackoff.TimeInterval.microSeconds(**50**) ,
   KafkaSpoutRetryExponentialBackoff.TimeInterval.milliSeconds(**5**) , 1 ,
   KafkaSpoutRetryExponentialBackoff.TimeInterval.seconds(**1**) ) ;

我不确定应该为拓扑\u喷口\u等待\u策略和背压\u干扰器\u高\u水印设置什么值
那么，上述参数和数值的组合有助于控制喷口的摄取率呢？
如有任何建议，我们将不胜感激。
谢谢迦腻色迦