@vvcephei @mjsax this turns out to be harder than I thought. The tricky thing is that we originally want to 1) record the sensor only for the first time when we transit to "enforced processing" state, and 2) start the idleness timer only for the first time when we do not have all buffered but some buffered.
I tried to even implement a StreamTask State just like KafkaStreams and StreamThread, but that turns out to not be so elegant as well. So what I ended up now is this: we will record the sensor whenever we enforce processing, either for the first time or not, and hence we will only update idleStartTime once, and reset it whenever we have all buffered. LMK WDYT. [ Full content available at: https://github.com/apache/kafka/pull/5428 ] This message was relayed via gitbox.apache.org for [email protected]
