It is not: once `enforceProcessing` is set, we want to continue in that state until the next batch of records are enqueued and we not have all partitions buffered. Note that once we set the flag we update `lastEnforcedProcessingTime = now;` as well, but we do not want to disable enforce processing in the next run immediately.
[ Full content available at: https://github.com/apache/kafka/pull/5428 ] This message was relayed via gitbox.apache.org for [email protected]
