requestBackPressure() doesn't take effect

[zailushangde]

Hi Bill, in order to throttle the traffic, the requestBackPressure method is confirmed be called in the debug mode, which is hardcoded as below:

override def requestBackPressure(): Optional[lang.Long] = Optional.of(1L)

override def requestBuffer(): Optional[Integer] = Optional.empty()

however, the size of the consumed events is still same as the initial configuration StreamConfiguration().batchLimit(nakadiConfig.batchSize).

Any clue what I missed there, please?