Overall, the enforced-processing algorithm is unclear to me. * Following on @mjsax 's comment, it seems strange to set this right before we return true anyway. Note that this is currently the only place we set `enforceProcessing` to true.
* Also, it still seems to me that `maxTaskIdleMs` should count from the last time we process at all, not the last time we forced processing (same basic scenario I pointed out last time). Is this right? [ Full content available at: https://github.com/apache/kafka/pull/5428 ] This message was relayed via gitbox.apache.org for [email protected]
