Both good points. Basically, we should reset the timer when there is data for all input partitions. Thus, we should check after poll() if we can reset the timer (ie, in `StreamTask#addRecords()` each time all partitions have data)?
[ Full content available at: https://github.com/apache/kafka/pull/5428 ] This message was relayed via gitbox.apache.org for [email protected]
